package j.q.a;

import j.m;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final e.a.h<m<T>> f4408b;

    /* JADX INFO: renamed from: j.q.a.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: BodyObservable.java */
    private static class C0139a<R> implements e.a.m<m<R>> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        private final e.a.m<? super R> f4409b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        private boolean f4410f;

        C0139a(e.a.m<? super R> mVar) {
            this.f4409b = mVar;
        }

        @Override // e.a.m
        public void a() {
            if (this.f4410f) {
                return;
            }
            this.f4409b.a();
        }

        @Override // e.a.m
        public void b(Throwable th) {
            if (!this.f4410f) {
                this.f4409b.b(th);
                return;
            }
            AssertionError assertionError = new AssertionError("This should never happen! Report as a bug with the full stacktrace.");
            assertionError.initCause(th);
            e.a.w.a.p(assertionError);
        }

        @Override // e.a.m
        public void c(e.a.r.b bVar) {
            this.f4409b.c(bVar);
        }

        @Override // e.a.m
        /* JADX INFO: renamed from: e, reason: merged with bridge method [inline-methods] */
        public void d(m<R> mVar) {
            if (mVar.d()) {
                this.f4409b.d(mVar.a());
                return;
            }
            this.f4410f = true;
            d dVar = new d(mVar);
            try {
                this.f4409b.b(dVar);
            } catch (Throwable th) {
                e.a.s.b.b(th);
                e.a.w.a.p(new e.a.s.a(dVar, th));
            }
        }
    }

    a(e.a.h<m<T>> hVar) {
        this.f4408b = hVar;
    }

    @Override // e.a.h
    protected void S(e.a.m<? super T> mVar) {
        this.f4408b.e(new C0139a(mVar));
    }
}