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 a<T> extends h<T> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final h<b0<T>> f6907b;

    /* JADX INFO: renamed from: j.i0.a.a$a, reason: collision with other inner class name */
    public static class C0095a<R> implements l<b0<R>> {

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

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

        public C0095a(l<? super R> lVar) {
            this.f6908b = lVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            if (!this.f6909c) {
                this.f6908b.a(th);
                return;
            }
            AssertionError assertionError = new AssertionError("This should never happen! Report as a bug with the full stacktrace.");
            assertionError.initCause(th);
            d.a.u.a.v(assertionError);
        }

        @Override // d.a.l
        public void b() {
            if (this.f6909c) {
                return;
            }
            this.f6908b.b();
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            this.f6908b.c(bVar);
        }

        @Override // d.a.l
        /* JADX INFO: renamed from: e, reason: merged with bridge method [inline-methods] */
        public void d(b0<R> b0Var) {
            if (b0Var.a()) {
                this.f6908b.d(b0Var.f6876b);
                return;
            }
            this.f6909c = true;
            c cVar = new c(b0Var);
            try {
                this.f6908b.a(cVar);
            } catch (Throwable th) {
                n0.y(th);
                d.a.u.a.v(new d.a.q.a(cVar, th));
            }
        }
    }

    public a(h<b0<T>> hVar) {
        this.f6907b = hVar;
    }

    @Override // d.a.h
    public void o(l<? super T> lVar) {
        this.f6907b.e(new C0095a(lVar));
    }
}