package j.i0.a;

import a.a.a.a.c.n0;
import d.a.h;
import d.a.l;
import j.b0;

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

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

    public static final class a implements d.a.p.b {

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

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

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

        @Override // d.a.p.b
        public void dispose() {
            this.f6912c = true;
            this.f6911b.a();
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return this.f6912c;
        }
    }

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

    @Override // d.a.h
    public void o(l<? super b0<T>> lVar) {
        boolean z;
        j.b<T> bVarClone = this.f6910b.clone();
        a aVar = new a(bVarClone);
        lVar.c(aVar);
        if (aVar.f6912c) {
            return;
        }
        try {
            b0<T> b0VarO = bVarClone.o();
            if (!aVar.f6912c) {
                lVar.d(b0VarO);
            }
            if (aVar.f6912c) {
                return;
            }
            try {
                lVar.b();
            } catch (Throwable th) {
                th = th;
                z = true;
                n0.y(th);
                if (z) {
                    d.a.u.a.v(th);
                    return;
                }
                if (aVar.f6912c) {
                    return;
                }
                try {
                    lVar.a(th);
                } catch (Throwable th2) {
                    n0.y(th2);
                    d.a.u.a.v(new d.a.q.a(th, th2));
                }
            }
        } catch (Throwable th3) {
            th = th3;
            z = false;
        }
    }
}