71 lines
2.2 KiB
Java
71 lines
2.2 KiB
Java
package o;
|
|
|
|
import java.util.concurrent.CompletionStage;
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
import java.util.function.BiConsumer;
|
|
|
|
/* renamed from: o.fTv, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13208fTv<T> extends AbstractC13163fSk<T> {
|
|
private CompletionStage<T> a;
|
|
|
|
public C13208fTv(CompletionStage<T> completionStage) {
|
|
this.a = completionStage;
|
|
}
|
|
|
|
@Override // o.AbstractC13163fSk
|
|
public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
HBt hBt = new HBt();
|
|
LWm lWm = new LWm(interfaceC13174fSv, hBt);
|
|
hBt.lazySet(lWm);
|
|
interfaceC13174fSv.onSubscribe(lWm);
|
|
this.a.whenComplete(hBt);
|
|
}
|
|
|
|
/* renamed from: o.fTv$LWm */
|
|
/* loaded from: classes6.dex */
|
|
static final class LWm<T> extends fTO<T> implements BiConsumer<T, Throwable> {
|
|
private HBt<T> b;
|
|
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
@Override // java.util.function.BiConsumer
|
|
public final /* synthetic */ void accept(Object obj, Throwable th) {
|
|
Throwable th2 = th;
|
|
if (th2 != null) {
|
|
this.c.onError(th2);
|
|
} else if (obj != 0) {
|
|
d(obj);
|
|
} else {
|
|
this.c.onError(new NullPointerException("The CompletionStage terminated with null."));
|
|
}
|
|
}
|
|
|
|
LWm(InterfaceC13174fSv<? super T> interfaceC13174fSv, HBt<T> hBt) {
|
|
super(interfaceC13174fSv);
|
|
this.b = hBt;
|
|
}
|
|
|
|
@Override // o.fTO, o.fSJ
|
|
public final void dispose() {
|
|
super.dispose();
|
|
this.b.set(null);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.fTv$HBt */
|
|
/* loaded from: classes6.dex */
|
|
static final class HBt<T> extends AtomicReference<BiConsumer<T, Throwable>> implements BiConsumer<T, Throwable> {
|
|
HBt() {
|
|
}
|
|
|
|
@Override // java.util.function.BiConsumer
|
|
public final /* synthetic */ void accept(Object obj, Throwable th) {
|
|
Throwable th2 = th;
|
|
BiConsumer<T, Throwable> biConsumer = get();
|
|
if (biConsumer != null) {
|
|
biConsumer.accept(obj, th2);
|
|
}
|
|
}
|
|
}
|
|
}
|