package yp;

import java.util.concurrent.CompletableFuture;
import java.util.function.BiFunction;
import rm.n0;
import tp.u1;
import vm.g;

/* loaded from: classes3.dex */
final class a extends tp.a implements BiFunction {

    /* renamed from: s, reason: collision with root package name */
    private final CompletableFuture f52914s;

    public a(g gVar, CompletableFuture completableFuture) {
        super(gVar, true, true);
        this.f52914s = completableFuture;
    }

    @Override // tp.a
    protected void U0(Throwable th2, boolean z10) {
        this.f52914s.completeExceptionally(th2);
    }

    @Override // tp.a
    protected void V0(Object obj) {
        this.f52914s.complete(obj);
    }

    public void X0(Object obj, Throwable th2) {
        u1.a.a(this, null, 1, null);
    }

    @Override // java.util.function.BiFunction
    public /* bridge */ /* synthetic */ Object apply(Object obj, Object obj2) {
        X0(obj, (Throwable) obj2);
        return n0.f34904a;
    }
}
