package f.z.a;

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

/* JADX INFO: compiled from: CallExecuteObservable.java */
/* JADX INFO: loaded from: classes.dex */
final class c<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> f1779a;

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

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

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

        a(f.d<?> dVar) {
            this.f1780b = dVar;
        }

        public boolean a() {
            return this.f1781c;
        }

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

    c(f.d<T> dVar) {
        this.f1779a = dVar;
    }

    @Override // b.a.a.a.g
    protected void t(i<? super t<T>> iVar) {
        boolean z;
        f.d<T> dVarM5clone = this.f1779a.m5clone();
        a aVar = new a(dVarM5clone);
        iVar.c(aVar);
        if (aVar.a()) {
            return;
        }
        try {
            t<T> tVarExecute = dVarM5clone.execute();
            if (!aVar.a()) {
                iVar.d(tVarExecute);
            }
            if (aVar.a()) {
                return;
            }
            try {
                iVar.b();
            } catch (Throwable th) {
                th = th;
                z = true;
                b.a.a.c.b.a(th);
                if (z) {
                    b.a.a.g.a.p(th);
                    return;
                }
                if (aVar.a()) {
                    return;
                }
                try {
                    iVar.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));
                }
            }
        } catch (Throwable th3) {
            th = th3;
            z = false;
        }
    }
}