package o; import java.util.List; import o.C3592bAn; import o.ZI; import o.cZG; import o.wRi; /* renamed from: o.bAn, reason: case insensitive filesystem */ /* loaded from: classes4.dex */ public class C3592bAn extends ZI { private final C17121uB a; private final C17227ux b; public OH c; public List d; public final C17809ztu e; private final C17326vo g; @InterfaceC13391fZD public C3592bAn(C17809ztu c17809ztu, C17227ux c17227ux, C17121uB c17121uB, C16903sI c16903sI, C17326vo c17326vo) { super(c16903sI); this.e = c17809ztu; this.b = c17227ux; this.g = c17326vo; this.a = c17121uB; } public final int a(String str) { for (int i = 0; i < this.d.size(); i++) { if (this.d.get(i).a.equals(str)) { return i; } } return -1; } @Override // o.ZI public final void w_() { super.w_(); C17809ztu c17809ztu = this.e; if (!c17809ztu.h.isDisposed()) { c17809ztu.h.dispose(); } c17809ztu.c.a(); } /* renamed from: o.bAn$HBt */ /* loaded from: classes4.dex */ public final class HBt extends wRi.LWm { private C3592bAn d; /* JADX INFO: Access modifiers changed from: package-private */ public static /* synthetic */ void e() { } private HBt(C3592bAn c3592bAn) { this.d = c3592bAn; } @Override // o.wRi.LWm, o.InterfaceC13174fSv public final /* synthetic */ void onNext(Object obj) { C11805emK c11805emK = (C11805emK) obj; if (this.d.f != 0) { C3592bAn c3592bAn = this.d; c3592bAn.c = c3592bAn.b.b(c11805emK, this.d.e.a.T()); final List d = this.d.g.d(c11805emK.b); final List d2 = this.d.a.d((List) c11805emK.b); C3592bAn c3592bAn2 = this.d; ZI.IeS ieS = new ZI.IeS(d2) { // from class: o.bAr private List e; @Override // o.ZI.IeS public final void e(Object obj2) { ((cZG.IeS) obj2).d((List) this.e); } { this.e = d2; } }; if (c3592bAn2.f != 0) { ieS.e(c3592bAn2.f); } C3592bAn c3592bAn3 = this.d; ZI.IeS ieS2 = new ZI.IeS(d) { // from class: o.bAs private List e; @Override // o.ZI.IeS public final void e(Object obj2) { ((cZG.IeS) obj2).b(this.e); } { this.e = d; } }; if (c3592bAn3.f != 0) { ieS2.e(c3592bAn3.f); } } } @Override // o.wRi.LWm, o.InterfaceC13174fSv public final void onComplete() { C3592bAn.c(this.d); C3592bAn.f(this.d); } @Override // o.wRi.LWm, o.InterfaceC13174fSv public final void onError(Throwable th) { if (this.d.f == 0 || this.d.i(th)) { return; } C3592bAn.g(this.d); C3592bAn c3592bAn = this.d; ZI.IeS ieS = new ZI.IeS() { // from class: o.bAt @Override // o.ZI.IeS public final void e(Object obj) { C3592bAn.HBt.e(); } }; if (c3592bAn.f != 0) { ieS.e(c3592bAn.f); } } public /* synthetic */ HBt(C3592bAn c3592bAn, byte b) { this(c3592bAn); } } static /* synthetic */ void c(C3592bAn c3592bAn) { if (c3592bAn.f != 0) { c3592bAn.f.aq_(); } } static /* synthetic */ void f(C3592bAn c3592bAn) { if (c3592bAn.f != 0) { c3592bAn.f.u(); } } static /* synthetic */ void g(C3592bAn c3592bAn) { if (c3592bAn.f != 0) { c3592bAn.f.u(); } } }