118 lines
3.5 KiB
Java
118 lines
3.5 KiB
Java
package o;
|
|
|
|
import o.C0690Mh;
|
|
import o.C2915anc;
|
|
import o.ZI;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.anc, reason: case insensitive filesystem */
|
|
/* loaded from: classes3.dex */
|
|
public final class C2915anc extends ZI<InterfaceC9060dcb> {
|
|
private final C16361ni b;
|
|
public final xZj d;
|
|
public C0430Gj e;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
@InterfaceC13391fZD
|
|
public C2915anc(C16903sI c16903sI, xZj xzj, C16361ni c16361ni) {
|
|
super(c16903sI);
|
|
C14957gcv.e(xzj, "");
|
|
C14957gcv.e(c16361ni, "");
|
|
this.d = xzj;
|
|
this.b = c16361ni;
|
|
}
|
|
|
|
/* renamed from: o.anc$IeS */
|
|
/* loaded from: classes3.dex */
|
|
public final class IeS extends wRi.LWm<iAj> {
|
|
private C2915anc d;
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
final iAj iaj = (iAj) obj;
|
|
C14957gcv.e(iaj, "");
|
|
final C2915anc c2915anc = this.d;
|
|
ZI.IeS ieS = new ZI.IeS(c2915anc, iaj) { // from class: o.anf
|
|
private C2915anc d;
|
|
private iAj e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
C2915anc.IeS.d(this.d, this.e, (InterfaceC9060dcb) obj2);
|
|
}
|
|
|
|
{
|
|
this.d = c2915anc;
|
|
this.e = iaj;
|
|
}
|
|
};
|
|
if (c2915anc.f != 0) {
|
|
ieS.e(c2915anc.f);
|
|
}
|
|
}
|
|
|
|
public IeS(C2915anc c2915anc) {
|
|
this.d = c2915anc;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(final Throwable th) {
|
|
C14957gcv.e(th, "");
|
|
C2915anc.d(this.d);
|
|
final C2915anc c2915anc = this.d;
|
|
ZI.IeS ieS = new ZI.IeS(c2915anc, th) { // from class: o.ana
|
|
private Throwable a;
|
|
private C2915anc e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
C2915anc.IeS.d(this.e, this.a, (InterfaceC9060dcb) obj);
|
|
}
|
|
|
|
{
|
|
this.e = c2915anc;
|
|
this.a = th;
|
|
}
|
|
};
|
|
if (c2915anc.f != 0) {
|
|
ieS.e(c2915anc.f);
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onComplete() {
|
|
C2915anc.d(this.d);
|
|
super.onComplete();
|
|
}
|
|
|
|
public static /* synthetic */ void d(C2915anc c2915anc, Throwable th, InterfaceC9060dcb interfaceC9060dcb) {
|
|
C14957gcv.e(c2915anc, "");
|
|
C14957gcv.e(th, "");
|
|
interfaceC9060dcb.e(c2915anc.j.d(th, C0690Mh.IeS.JUST_DISMISS));
|
|
}
|
|
|
|
public static /* synthetic */ void d(C2915anc c2915anc, iAj iaj, InterfaceC9060dcb interfaceC9060dcb) {
|
|
C14957gcv.e(c2915anc, "");
|
|
C14957gcv.e(iaj, "");
|
|
interfaceC9060dcb.ar_();
|
|
C0430Gj c0430Gj = c2915anc.e;
|
|
interfaceC9060dcb.e(c0430Gj != null ? c2915anc.b.d(iaj, c0430Gj) : null);
|
|
}
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
xZj xzj = this.d;
|
|
if (!xzj.h.isDisposed()) {
|
|
xzj.h.dispose();
|
|
}
|
|
super.w_();
|
|
}
|
|
|
|
public static final /* synthetic */ void d(C2915anc c2915anc) {
|
|
if (c2915anc.f != 0) {
|
|
c2915anc.f.ar_();
|
|
}
|
|
}
|
|
}
|