package o; import java.util.Iterator; import java.util.Objects; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Stream; /* renamed from: o.fTu, reason: case insensitive filesystem */ /* loaded from: classes6.dex */ public final class C13207fTu extends AbstractC13163fSk { private fSS> b; private AbstractC13163fSk d; public C13207fTu(AbstractC13163fSk abstractC13163fSk, fSS> fss) { this.d = abstractC13163fSk; this.b = fss; } @Override // o.AbstractC13163fSk public final void subscribeActual(InterfaceC13174fSv interfaceC13174fSv) { AbstractC13163fSk abstractC13163fSk = this.d; if (abstractC13163fSk instanceof InterfaceC13189fTc) { try { Object d = ((InterfaceC13189fTc) abstractC13163fSk).d(); Stream stream = d != null ? (Stream) Objects.requireNonNull(this.b.a(d), "The mapper returned a null Stream") : null; if (stream != null) { C13206fTt.c(interfaceC13174fSv, stream); return; } else { EnumC13195fTi.e(interfaceC13174fSv); return; } } catch (Throwable th) { C13147fSI.c(th); EnumC13195fTi.a(th, interfaceC13174fSv); return; } } abstractC13163fSk.subscribe(new IeS(interfaceC13174fSv, this.b)); } /* renamed from: o.fTu$IeS */ /* loaded from: classes6.dex */ static final class IeS extends AtomicInteger implements InterfaceC13174fSv, fSJ { private fSS> a; private fSJ b; private volatile boolean c; private boolean d; private InterfaceC13174fSv e; IeS(InterfaceC13174fSv interfaceC13174fSv, fSS> fss) { this.e = interfaceC13174fSv; this.a = fss; } @Override // o.InterfaceC13174fSv public final void onSubscribe(fSJ fsj) { if (EnumC13192fTf.d(this.b, fsj)) { this.b = fsj; this.e.onSubscribe(this); } } @Override // o.InterfaceC13174fSv public final void onNext(T t) { if (this.d) { return; } try { Stream stream = (Stream) Objects.requireNonNull(this.a.a(t), "The mapper returned a null Stream"); try { Iterator it = stream.iterator(); while (true) { if (!it.hasNext()) { break; } if (this.c) { this.d = true; break; } Object requireNonNull = Objects.requireNonNull(it.next(), "The Stream's Iterator.next returned a null value"); if (this.c) { this.d = true; break; } this.e.onNext(requireNonNull); if (this.c) { this.d = true; break; } } if (stream != null) { stream.close(); } } finally { } } catch (Throwable th) { C13147fSI.c(th); this.b.dispose(); onError(th); } } @Override // o.InterfaceC13174fSv public final void onError(Throwable th) { if (this.d) { C13418fZu.c(th); } else { this.d = true; this.e.onError(th); } } @Override // o.InterfaceC13174fSv public final void onComplete() { if (this.d) { return; } this.d = true; this.e.onComplete(); } @Override // o.fSJ public final void dispose() { this.c = true; this.b.dispose(); } @Override // o.fSJ public final boolean isDisposed() { return this.c; } } }