package o; import java.util.Collection; /* loaded from: classes6.dex */ public final class fXF> extends fUX { private InterfaceC13189fTc a; public fXF(InterfaceC13169fSq interfaceC13169fSq, InterfaceC13189fTc interfaceC13189fTc) { super(interfaceC13169fSq); this.a = interfaceC13189fTc; } @Override // o.AbstractC13163fSk public final void subscribeActual(InterfaceC13174fSv interfaceC13174fSv) { try { this.c.subscribe(new Sts(interfaceC13174fSv, (Collection) fYR.d(this.a.d(), "The collectionSupplier returned a null Collection."))); } catch (Throwable th) { C13147fSI.c(th); EnumC13195fTi.a(th, interfaceC13174fSv); } } /* loaded from: classes6.dex */ static final class Sts> implements InterfaceC13174fSv, fSJ { private U a; private fSJ d; private InterfaceC13174fSv e; Sts(InterfaceC13174fSv interfaceC13174fSv, U u) { this.e = interfaceC13174fSv; this.a = u; } @Override // o.InterfaceC13174fSv public final void onSubscribe(fSJ fsj) { if (EnumC13192fTf.d(this.d, fsj)) { this.d = fsj; this.e.onSubscribe(this); } } @Override // o.fSJ public final void dispose() { this.d.dispose(); } @Override // o.fSJ public final boolean isDisposed() { return this.d.isDisposed(); } @Override // o.InterfaceC13174fSv public final void onNext(T t) { this.a.add(t); } @Override // o.InterfaceC13174fSv public final void onError(Throwable th) { this.a = null; this.e.onError(th); } @Override // o.InterfaceC13174fSv public final void onComplete() { U u = this.a; this.a = null; this.e.onNext(u); this.e.onComplete(); } } }