package o; import java.util.List; import java.util.Objects; import o.InterfaceC6669cZl; import o.ZI; import o.bEI; import o.wRi; /* loaded from: classes4.dex */ public class bEI extends ZI { private List a; private final C17340vt b; public final C17752zVW d; @InterfaceC13391fZD public bEI(C16903sI c16903sI, C17752zVW c17752zVW, C17340vt c17340vt) { super(c16903sI); this.b = c17340vt; this.d = c17752zVW; } /* loaded from: classes4.dex */ public class Sts extends wRi.LWm> { private bEI e; public Sts(bEI bei) { this.e = bei; } @Override // o.wRi.LWm, o.InterfaceC13174fSv public final /* synthetic */ void onNext(Object obj) { List list = (List) obj; bEI.e(this.e); if (list != null) { bEI bei = this.e; C17340vt unused = bei.b; final C17340vt c17340vt = this.e.b; Objects.requireNonNull(c17340vt); bei.a = (List) C16157lj.c(new Object[]{list, new InterfaceC1244Ytw(c17340vt) { // from class: o.bEH private C17340vt a; @Override // o.InterfaceC1244Ytw public final Object d(Object obj2) { return C17340vt.c((Gbo) obj2); } { this.a = c17340vt; } }}, -1846295624, 1846295631, (int) System.currentTimeMillis()); bEI bei2 = this.e; ZI.IeS ieS = new ZI.IeS(this) { // from class: o.bEL private bEI.Sts d; @Override // o.ZI.IeS public final void e(Object obj2) { ((InterfaceC6669cZl.RVV) obj2).e(this.d.e.a); } { this.d = this; } }; if (bei2.f != 0) { ieS.e(bei2.f); } } } @Override // o.wRi.LWm, o.InterfaceC13174fSv public final void onError(Throwable th) { bEI.c(this.e); bEI.d(this.e, th); } } static /* synthetic */ void c(bEI bei) { if (bei.f != 0) { bei.f.ar_(); } } static /* synthetic */ void d(bEI bei, Throwable th) { if (bei.b(th)) { bei.d(bei.j.e(th)); } } static /* synthetic */ void e(bEI bei) { if (bei.f != 0) { bei.f.ar_(); } } @Override // o.ZI public final void w_() { C17752zVW c17752zVW = this.d; if (!c17752zVW.h.isDisposed()) { c17752zVW.h.dispose(); } super.w_(); } }