package o;

import o.C15715hv;
import o.C3058aqO;
import o.InterfaceC9081dcw;
import o.ZI;
import o.wRi;
import org.threeten.bp.OffsetDateTime;

/* renamed from: o.aqO, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public final class C3058aqO extends ZI<InterfaceC9081dcw.Sts> {
    public GP a;
    public final xZj b;
    private final YnH 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 C3058aqO(C16903sI c16903sI, xZj xzj, C16398nw c16398nw, C16406nz c16406nz, YnH ynH) {
        super(c16903sI);
        C14957gcv.e(xzj, "");
        C14957gcv.e(c16398nw, "");
        C14957gcv.e(c16406nz, "");
        C14957gcv.e(ynH, "");
        this.b = xzj;
        this.d = c16398nw;
        this.e = c16406nz;
        this.c = ynH;
    }

    /* renamed from: o.aqO$LWm */
    /* loaded from: classes4.dex */
    public final class LWm extends wRi.LWm<RkK> {
        private C3058aqO e;

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final RkK rkK = (RkK) obj;
            C14957gcv.e(rkK, "");
            final C3058aqO c3058aqO = this.e;
            ZI.IeS ieS = new ZI.IeS(c3058aqO, rkK) { // from class: o.aqX
                private C3058aqO b;
                private RkK c;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C3058aqO.LWm.a(this.b, this.c, (InterfaceC9081dcw.Sts) obj2);
                }

                {
                    this.b = c3058aqO;
                    this.c = rkK;
                }
            };
            if (c3058aqO.f != 0) {
                ieS.e(c3058aqO.f);
            }
        }

        public LWm(C3058aqO c3058aqO) {
            this.e = c3058aqO;
        }

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

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C3058aqO.LWm.c(this.e, this.a, (InterfaceC9081dcw.Sts) obj);
                }

                {
                    this.e = c3058aqO;
                    this.a = th;
                }
            };
            if (c3058aqO.f != 0) {
                ieS.e(c3058aqO.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            C3058aqO.d(this.e);
        }

        public static /* synthetic */ void c(C3058aqO c3058aqO, Throwable th, final InterfaceC9081dcw.Sts sts) {
            C14957gcv.e(c3058aqO, "");
            C14957gcv.e(th, "");
            C3058aqO.d(c3058aqO);
            if (c3058aqO.b(th, "1035")) {
                sts.d(c3058aqO.j.e(th).c);
            } else {
                sts.e(c3058aqO.j.c(th, new Runnable(sts) { // from class: o.aqR
                    private InterfaceC9081dcw.Sts b;

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

                    {
                        this.b = sts;
                    }
                }));
            }
        }

        public static /* synthetic */ void a(C3058aqO c3058aqO, RkK rkK, InterfaceC9081dcw.Sts sts) {
            C14957gcv.e(c3058aqO, "");
            C14957gcv.e(rkK, "");
            GP gp = c3058aqO.a;
            GL gl = null;
            GP e = gp != null ? c3058aqO.d.e(gp, rkK, c3058aqO.c.b.T()) : null;
            if (e != null) {
                C16406nz c16406nz = c3058aqO.e;
                boolean z = e.j;
                C14957gcv.e(rkK, "");
                String str = (String) C16157lj.c(new Object[]{c16406nz, OffsetDateTime.parse(rkK.a)}, 838289628, -838289623, System.identityHashCode(c16406nz));
                GL gl2 = new GL((byte) 0);
                String string = c16406nz.e.getString(C15715hv.tOB.ref_id_label);
                String str2 = rkK.c;
                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;
            }
            sts.a(gl, e);
        }
    }

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

    public static final /* synthetic */ void d(C3058aqO c3058aqO) {
        if (c3058aqO.f != 0) {
            c3058aqO.f.ar_();
        }
    }
}