package j.q.a;

import j.m;

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

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

    /* JADX INFO: compiled from: CallExecuteObservable.java */
    private static final class a implements e.a.r.b {

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

        a(j.b<?> bVar) {
            this.f4416b = bVar;
        }

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

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

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

    @Override // e.a.h
    protected void S(e.a.m<? super m<T>> mVar) {
        boolean z;
        j.b<T> bVarM6clone = this.f4415b.m6clone();
        mVar.c(new a(bVarM6clone));
        try {
            m<T> mVarExecute = bVarM6clone.execute();
            if (!bVarM6clone.isCanceled()) {
                mVar.d(mVarExecute);
            }
            if (bVarM6clone.isCanceled()) {
                return;
            }
            try {
                mVar.a();
            } catch (Throwable th) {
                th = th;
                z = true;
                e.a.s.b.b(th);
                if (z) {
                    e.a.w.a.p(th);
                    return;
                }
                if (bVarM6clone.isCanceled()) {
                    return;
                }
                try {
                    mVar.b(th);
                } catch (Throwable th2) {
                    e.a.s.b.b(th2);
                    e.a.w.a.p(new e.a.s.a(th, th2));
                }
            }
        } catch (Throwable th3) {
            th = th3;
            z = false;
        }
    }
}