package j.q.a;

import j.m;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final j.b<T> f4411b;

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        private final e.a.m<? super m<T>> f4413f;

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

        a(j.b<?> bVar, e.a.m<? super m<T>> mVar) {
            this.f4412b = bVar;
            this.f4413f = mVar;
        }

        @Override // j.d
        public void a(j.b<T> bVar, m<T> mVar) {
            if (bVar.isCanceled()) {
                return;
            }
            try {
                this.f4413f.d(mVar);
                if (bVar.isCanceled()) {
                    return;
                }
                this.f4414g = true;
                this.f4413f.a();
            } catch (Throwable th) {
                if (this.f4414g) {
                    e.a.w.a.p(th);
                    return;
                }
                if (bVar.isCanceled()) {
                    return;
                }
                try {
                    this.f4413f.b(th);
                } catch (Throwable th2) {
                    e.a.s.b.b(th2);
                    e.a.w.a.p(new e.a.s.a(th, th2));
                }
            }
        }

        @Override // j.d
        public void b(j.b<T> bVar, Throwable th) {
            if (bVar.isCanceled()) {
                return;
            }
            try {
                this.f4413f.b(th);
            } catch (Throwable th2) {
                e.a.s.b.b(th2);
                e.a.w.a.p(new e.a.s.a(th, th2));
            }
        }

        @Override // e.a.r.b
        public void dispose() {
            this.f4412b.cancel();
        }

        @Override // e.a.r.b
        public boolean isDisposed() {
            return this.f4412b.isCanceled();
        }
    }

    b(j.b<T> bVar) {
        this.f4411b = bVar;
    }

    @Override // e.a.h
    protected void S(e.a.m<? super m<T>> mVar) {
        j.b<T> bVarM6clone = this.f4411b.m6clone();
        a aVar = new a(bVarM6clone, mVar);
        mVar.c(aVar);
        bVarM6clone.d(aVar);
    }
}