package o;

import o.C3558azn;
import o.ZI;
import o.wRi;

/* renamed from: o.azn, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C3558azn extends ZI<InterfaceC9131ddt> {
    private final iRl a;
    public XOD b;
    public AHH c;
    public bSN d;
    private C0509Ig e;
    private C16421oH g;

    @InterfaceC13391fZD
    public C3558azn(C16903sI c16903sI, XOD xod, bSN bsn, C16421oH c16421oH, AHH ahh, iRl irl) {
        super(c16903sI);
        this.b = xod;
        this.d = bsn;
        this.g = c16421oH;
        this.a = irl;
        this.c = ahh;
    }

    /* renamed from: o.azn$3, reason: invalid class name */
    /* loaded from: classes4.dex */
    public class AnonymousClass3 extends wRi.LWm<C0509Ig> {
        private C3558azn c;

        public AnonymousClass3(C3558azn c3558azn) {
            this.c = c3558azn;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final C0509Ig c0509Ig = (C0509Ig) obj;
            this.c.e = c0509Ig;
            C3558azn c3558azn = this.c;
            ZI.IeS ieS = new ZI.IeS(this, c0509Ig) { // from class: o.azu
                private C3558azn.AnonymousClass3 b;
                private C0509Ig e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C3558azn.AnonymousClass3.d(this.b, this.e, (InterfaceC9131ddt) obj2);
                }

                {
                    this.b = this;
                    this.e = c0509Ig;
                }
            };
            if (c3558azn.f != 0) {
                ieS.e(c3558azn.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            C3558azn c3558azn = this.c;
            ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.azw
                private C3558azn.AnonymousClass3 a;
                private Throwable d;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C3558azn.AnonymousClass3.c(this.a, this.d, (InterfaceC9131ddt) obj);
                }

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

        public static /* synthetic */ void c(AnonymousClass3 anonymousClass3, Throwable th, InterfaceC9131ddt interfaceC9131ddt) {
            interfaceC9131ddt.ar_();
            interfaceC9131ddt.e(anonymousClass3.c.j.e(th));
        }

        public static /* synthetic */ void d(AnonymousClass3 anonymousClass3, C0509Ig c0509Ig, InterfaceC9131ddt interfaceC9131ddt) {
            boolean V = anonymousClass3.c.a.a.V();
            interfaceC9131ddt.ar_();
            interfaceC9131ddt.c(!V);
            interfaceC9131ddt.d(c0509Ig);
            if (V) {
                interfaceC9131ddt.b(anonymousClass3.c.e, false);
            }
        }
    }
}