package o;

import android.net.Uri;
import o.InterfaceC9010dbe;
import o.ZI;
import o.wRi;

/* renamed from: o.cSo, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C6432cSo extends ZI<InterfaceC9010dbe.XOs> {
    public EnumC1264Zf a;
    public String b;
    public boolean c;
    public boolean d;
    public Uri e;
    public final RVV g;
    public int h;
    public int i;
    private final cRG k;
    private final PLy m;
    private final cRH n;

    /* renamed from: o.cSo$HBt */
    /* loaded from: classes4.dex */
    public interface HBt<T> {
        void d(T t);

        void d(String str);

        void e(boolean z);
    }

    @InterfaceC13391fZD
    public C6432cSo(C0307Du c0307Du, PLy pLy, cRH crh, cRG crg) {
        super(c0307Du);
        this.c = true;
        this.h = 0;
        this.i = 0;
        this.b = "";
        this.m = pLy;
        this.k = crg;
        this.n = crh;
        this.g = new RVV(this, (byte) 0);
    }

    /* renamed from: o.cSo$RVV */
    /* loaded from: classes4.dex */
    public class RVV {
        private C6432cSo e;

        private RVV(C6432cSo c6432cSo) {
            this.e = c6432cSo;
        }

        public final HBt d(EnumC1264Zf enumC1264Zf) {
            HBt hBt;
            if (!enumC1264Zf.equals(EnumC1264Zf.DIRECT_DEBIT)) {
                hBt = this.e.n;
                this.e.n.c(this.e.b);
            } else {
                hBt = this.e.k;
            }
            hBt.d((HBt) this.e.f);
            return hBt;
        }

        /* synthetic */ RVV(C6432cSo c6432cSo, byte b) {
            this(c6432cSo);
        }
    }

    public final void b() {
        this.c = false;
        if (this.j instanceof C0307Du) {
            d(((C0307Du) this.j).a(new Runnable(this) { // from class: o.cSp
                private C6432cSo e;

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

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

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.cSo$LWm */
    /* loaded from: classes4.dex */
    public final class LWm extends wRi.LWm<byte[]> {
        private C6432cSo c;

        private LWm(C6432cSo c6432cSo) {
            this.c = c6432cSo;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final byte[] bArr = (byte[]) obj;
            C6432cSo c6432cSo = this.c;
            ZI.IeS ieS = new ZI.IeS(bArr) { // from class: o.cSs
                private byte[] c;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC9010dbe.XOs) obj2).c(this.c);
                }

                {
                    this.c = bArr;
                }
            };
            if (c6432cSo.f != 0) {
                ieS.e(c6432cSo.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C6432cSo.i(this.c);
            this.c.b();
        }

        /* synthetic */ LWm(C6432cSo c6432cSo, byte b) {
            this(c6432cSo);
        }
    }

    static /* synthetic */ void i(C6432cSo c6432cSo) {
        if (c6432cSo.f != 0) {
            c6432cSo.f.ar_();
        }
    }

    public final void VI_(Uri uri, int i, int i2) {
        this.h = i;
        this.i = i2;
        if (this.d) {
            this.e = uri;
            return;
        }
        if (this.f != 0) {
            this.f.y();
        }
        this.m.b(uri != null ? uri.toString() : null, i, i2);
        PLy pLy = this.m;
        pLy.d(pLy.i, new LWm(this, (byte) 0));
        this.e = null;
    }
}