package o;

/* renamed from: o.hB, reason: case insensitive filesystem */
/* loaded from: classes3.dex */
public abstract class AbstractC15611hB<REQUEST, RESPONSE> extends C15620hF {
    public fSJ b;
    public boolean c;

    protected abstract void b(InterfaceC13176fSx<RESPONSE> interfaceC13176fSx, REQUEST request);

    public AbstractC15611hB() {
        super((byte) 0);
    }

    /* renamed from: o.hB$IeS */
    /* loaded from: classes3.dex */
    public static final class IeS implements InterfaceC13176fSx<RESPONSE> {
        private InterfaceC14894gbR<RESPONSE, C14866gag> a;
        private InterfaceC14894gbR<Throwable, C14866gag> c;
        private AbstractC15611hB<REQUEST, RESPONSE> e;

        /* JADX WARN: Multi-variable type inference failed */
        IeS(AbstractC15611hB<REQUEST, RESPONSE> abstractC15611hB, InterfaceC14894gbR<? super RESPONSE, C14866gag> interfaceC14894gbR, InterfaceC14894gbR<? super Throwable, C14866gag> interfaceC14894gbR2) {
            this.e = abstractC15611hB;
            this.a = interfaceC14894gbR;
            this.c = interfaceC14894gbR2;
        }

        @Override // o.InterfaceC13176fSx
        public final void onError(Throwable th) {
            C14957gcv.e(th, "");
            this.e.c = false;
            this.c.invoke(th);
        }

        @Override // o.InterfaceC13176fSx
        public final void onSubscribe(fSJ fsj) {
            C14957gcv.e(fsj, "");
            this.e.b = fsj;
        }

        @Override // o.InterfaceC13176fSx
        public final void e(RESPONSE response) {
            this.e.c = false;
            this.a.invoke(response);
        }
    }

    public final void d(InterfaceC14894gbR<? super RESPONSE, C14866gag> interfaceC14894gbR, InterfaceC14894gbR<? super Throwable, C14866gag> interfaceC14894gbR2, REQUEST request) {
        C14957gcv.e(interfaceC14894gbR, "");
        C14957gcv.e(interfaceC14894gbR2, "");
        this.c = true;
        IeS ieS = new IeS(this, interfaceC14894gbR, interfaceC14894gbR2);
        fSJ fsj = this.b;
        if (fsj != null && !fsj.isDisposed()) {
            this.c = false;
            fsj.dispose();
        }
        b(ieS, request);
    }

    @Override // o.C15620hF
    public final void a() {
        fSJ fsj = this.b;
        if (fsj != null && !fsj.isDisposed()) {
            this.c = false;
            fsj.dispose();
        }
        super.a();
    }
}