package l.h0.a;

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

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

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

    /* JADX INFO: renamed from: l.h0.a.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: BodyObservable.java */
    public static class C0089a<R> implements n<b0<R>> {

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

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

        public C0089a(n<? super R> nVar) {
            this.f5020b = nVar;
        }

        @Override // f.a.n
        public void a(Throwable th) {
            if (!this.f5021e) {
                this.f5020b.a(th);
                return;
            }
            AssertionError assertionError = new AssertionError("This should never happen! Report as a bug with the full stacktrace.");
            assertionError.initCause(th);
            f.a.y.a.C0(assertionError);
        }

        @Override // f.a.n
        public void b(f.a.t.b bVar) {
            this.f5020b.b(bVar);
        }

        @Override // f.a.n
        /* JADX INFO: renamed from: d, reason: merged with bridge method [inline-methods] */
        public void c(b0<R> b0Var) {
            if (b0Var.a()) {
                this.f5020b.c(b0Var.f4997b);
                return;
            }
            this.f5021e = true;
            c cVar = new c(b0Var);
            try {
                this.f5020b.a(cVar);
            } catch (Throwable th) {
                d.i.c.a.L(th);
                f.a.y.a.C0(new f.a.u.a(cVar, th));
            }
        }

        @Override // f.a.n
        public void onComplete() {
            if (this.f5021e) {
                return;
            }
            this.f5020b.onComplete();
        }
    }

    public a(i<b0<T>> iVar) {
        this.f5019b = iVar;
    }

    @Override // f.a.i
    public void v(n<? super T> nVar) {
        this.f5019b.d(new C0089a(nVar));
    }
}