package l.h0.a;

import f.a.i;
import f.a.n;
import l.b0;

/* JADX INFO: compiled from: CallExecuteObservable.java */
/* JADX INFO: loaded from: classes.dex */
public final class b<T> extends i<b0<T>> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final l.b<T> f5022b;

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

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final l.b<?> f5023b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public volatile boolean f5024e;

        public a(l.b<?> bVar) {
            this.f5023b = bVar;
        }

        @Override // f.a.t.b
        public void dispose() {
            this.f5024e = true;
            this.f5023b.cancel();
        }
    }

    public b(l.b<T> bVar) {
        this.f5022b = bVar;
    }

    @Override // f.a.i
    public void v(n<? super b0<T>> nVar) {
        boolean z;
        l.b<T> bVarClone = this.f5022b.clone();
        a aVar = new a(bVarClone);
        nVar.b(aVar);
        if (aVar.f5024e) {
            return;
        }
        try {
            b0<T> b0VarExecute = bVarClone.execute();
            if (!aVar.f5024e) {
                nVar.c(b0VarExecute);
            }
            if (aVar.f5024e) {
                return;
            }
            try {
                nVar.onComplete();
            } catch (Throwable th) {
                th = th;
                z = true;
                d.i.c.a.L(th);
                if (z) {
                    f.a.y.a.C0(th);
                    return;
                }
                if (aVar.f5024e) {
                    return;
                }
                try {
                    nVar.a(th);
                } catch (Throwable th2) {
                    d.i.c.a.L(th2);
                    f.a.y.a.C0(new f.a.u.a(th, th2));
                }
            }
        } catch (Throwable th3) {
            th = th3;
            z = false;
        }
    }
}