package o;

import o.C15715hv;
import o.C3076aqg;
import o.InterfaceC9079dcu;
import o.ZI;
import o.wRi;
import org.threeten.bp.OffsetDateTime;

/* renamed from: o.aqg, reason: case insensitive filesystem */
/* loaded from: classes3.dex */
public final class C3076aqg extends ZI<InterfaceC9079dcu.IeS> {
    public final xZj a;
    private final YnH b;
    public GR c;
    private final C16398nw d;
    private final C16406nz e;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    @InterfaceC13391fZD
    public C3076aqg(C16903sI c16903sI, xZj xzj, C16398nw c16398nw, C16406nz c16406nz, YnH ynH) {
        super(c16903sI);
        C14957gcv.e(c16903sI, "");
        C14957gcv.e(xzj, "");
        C14957gcv.e(c16398nw, "");
        C14957gcv.e(c16406nz, "");
        C14957gcv.e(ynH, "");
        this.a = xzj;
        this.d = c16398nw;
        this.e = c16406nz;
        this.b = ynH;
    }

    /* renamed from: o.aqg$HBt */
    /* loaded from: classes3.dex */
    public final class HBt extends wRi.LWm<C6357cQd> {
        private C3076aqg e;

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final C6357cQd c6357cQd = (C6357cQd) obj;
            C14957gcv.e(c6357cQd, "");
            final C3076aqg c3076aqg = this.e;
            ZI.IeS ieS = new ZI.IeS(c3076aqg, c6357cQd) { // from class: o.aqn
                private C6357cQd b;
                private C3076aqg e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C3076aqg.HBt.a(this.e, this.b, (InterfaceC9079dcu.IeS) obj2);
                }

                {
                    this.e = c3076aqg;
                    this.b = c6357cQd;
                }
            };
            if (c3076aqg.f != 0) {
                ieS.e(c3076aqg.f);
            }
        }

        public HBt(C3076aqg c3076aqg) {
            this.e = c3076aqg;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            C14957gcv.e(th, "");
            final C3076aqg c3076aqg = this.e;
            C14957gcv.e(th, "");
            ZI.IeS ieS = new ZI.IeS(c3076aqg, th) { // from class: o.aqf
                private Throwable c;
                private C3076aqg e;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C3076aqg.b(this.e, this.c, (InterfaceC9079dcu.IeS) obj);
                }

                {
                    this.e = c3076aqg;
                    this.c = th;
                }
            };
            if (c3076aqg.f != 0) {
                ieS.e(c3076aqg.f);
            }
        }

        public static /* synthetic */ void a(C3076aqg c3076aqg, C6357cQd c6357cQd, InterfaceC9079dcu.IeS ieS) {
            C14957gcv.e(c3076aqg, "");
            C14957gcv.e(c6357cQd, "");
            C3076aqg.b(c3076aqg);
            GR gr = c3076aqg.c;
            GL gl = null;
            GR d = gr != null ? c3076aqg.d.d(gr, c6357cQd, c3076aqg.b.b.T()) : null;
            if (d != null) {
                C16406nz c16406nz = c3076aqg.e;
                boolean z = d.i;
                C14957gcv.e(c6357cQd, "");
                String str = (String) C16157lj.c(new Object[]{c16406nz, OffsetDateTime.parse(c6357cQd.e)}, 838289628, -838289623, System.identityHashCode(c16406nz));
                GL gl2 = new GL((byte) 0);
                String string = c16406nz.e.getString(C15715hv.tOB.ref_id_label);
                String str2 = c6357cQd.b;
                StringBuilder sb = new StringBuilder();
                sb.append(string);
                sb.append(" ");
                sb.append(str2);
                gl2.e = sb.toString();
                gl2.a = str;
                gl2.b = c16406nz.b(z);
                gl = gl2;
            }
            ieS.c(gl, d);
        }
    }

    @Override // o.ZI
    public final void w_() {
        xZj xzj = this.a;
        if (!xzj.h.isDisposed()) {
            xzj.h.dispose();
        }
        YnH ynH = this.b;
        if (!ynH.h.isDisposed()) {
            ynH.h.dispose();
        }
        super.w_();
    }

    public static /* synthetic */ void b(C3076aqg c3076aqg, Throwable th, final InterfaceC9079dcu.IeS ieS) {
        C14957gcv.e(c3076aqg, "");
        C14957gcv.e(th, "");
        if (c3076aqg.f != 0) {
            c3076aqg.f.ar_();
        }
        if (c3076aqg.b(th, "1035")) {
            ieS.a(c3076aqg.j.e(th));
        } else {
            ieS.e(c3076aqg.j.c(th, new Runnable(ieS) { // from class: o.aqm
                private InterfaceC9079dcu.IeS e;

                @Override // java.lang.Runnable
                public final void run() {
                    this.e.I_();
                }

                {
                    this.e = ieS;
                }
            }));
        }
    }

    public static final /* synthetic */ void b(C3076aqg c3076aqg) {
        if (c3076aqg.f != 0) {
            c3076aqg.f.ar_();
        }
    }
}