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 extends AbstractC13163fSk { private CompletionStage a; public C13208fTv(CompletionStage completionStage) { this.a = completionStage; } @Override // o.AbstractC13163fSk public final void subscribeActual(InterfaceC13174fSv 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 extends fTO implements BiConsumer { private HBt 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 interfaceC13174fSv, HBt 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 extends AtomicReference> implements BiConsumer { HBt() { } @Override // java.util.function.BiConsumer public final /* synthetic */ void accept(Object obj, Throwable th) { Throwable th2 = th; BiConsumer biConsumer = get(); if (biConsumer != null) { biConsumer.accept(obj, th2); } } } }