package f.z.a;

import b.a.a.a.i;
import f.t;

/* JADX INFO: compiled from: CallEnqueueObservable.java */
/* JADX INFO: loaded from: classes.dex */
final class b<T> extends b.a.a.a.g<t<T>> {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private final f.d<T> f1774a;

    /* JADX INFO: compiled from: CallEnqueueObservable.java */
    private static final class a<T> implements b.a.a.b.b, f.f<T> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        private final f.d<?> f1775b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final i<? super t<T>> f1776c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        private volatile boolean f1777d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        boolean f1778e = false;

        a(f.d<?> dVar, i<? super t<T>> iVar) {
            this.f1775b = dVar;
            this.f1776c = iVar;
        }

        @Override // f.f
        public void a(f.d<T> dVar, Throwable th) {
            if (dVar.isCanceled()) {
                return;
            }
            try {
                this.f1776c.a(th);
            } catch (Throwable th2) {
                b.a.a.c.b.a(th2);
                b.a.a.g.a.p(new b.a.a.c.a(th, th2));
            }
        }

        @Override // f.f
        public void b(f.d<T> dVar, t<T> tVar) {
            if (this.f1777d) {
                return;
            }
            try {
                this.f1776c.d(tVar);
                if (this.f1777d) {
                    return;
                }
                this.f1778e = true;
                this.f1776c.b();
            } catch (Throwable th) {
                b.a.a.c.b.a(th);
                if (this.f1778e) {
                    b.a.a.g.a.p(th);
                    return;
                }
                if (this.f1777d) {
                    return;
                }
                try {
                    this.f1776c.a(th);
                } catch (Throwable th2) {
                    b.a.a.c.b.a(th2);
                    b.a.a.g.a.p(new b.a.a.c.a(th, th2));
                }
            }
        }

        public boolean c() {
            return this.f1777d;
        }

        @Override // b.a.a.b.b
        public void dispose() {
            this.f1777d = true;
            this.f1775b.cancel();
        }
    }

    b(f.d<T> dVar) {
        this.f1774a = dVar;
    }

    @Override // b.a.a.a.g
    protected void t(i<? super t<T>> iVar) {
        f.d<T> dVarM5clone = this.f1774a.m6clone();
        a aVar = new a(dVarM5clone, iVar);
        iVar.c(aVar);
        if (aVar.c()) {
            return;
        }
        dVarM5clone.v(aVar);
    }
}