package f.z.a;

import b.a.a.a.i;
import f.t;

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

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private final b.a.a.a.g<t<T>> f1771a;

    /* JADX INFO: renamed from: f.z.a.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: BodyObservable.java */
    private static class C0040a<R> implements i<t<R>> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        private final i<? super R> f1772b;

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

        C0040a(i<? super R> iVar) {
            this.f1772b = iVar;
        }

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

        @Override // b.a.a.a.i
        public void b() {
            if (this.f1773c) {
                return;
            }
            this.f1772b.b();
        }

        @Override // b.a.a.a.i
        public void c(b.a.a.b.b bVar) {
            this.f1772b.c(bVar);
        }

        @Override // b.a.a.a.i
        /* JADX INFO: renamed from: e, reason: merged with bridge method [inline-methods] */
        public void d(t<R> tVar) {
            if (tVar.d()) {
                this.f1772b.d(tVar.a());
                return;
            }
            this.f1773c = true;
            d dVar = new d(tVar);
            try {
                this.f1772b.a(dVar);
            } catch (Throwable th) {
                b.a.a.c.b.a(th);
                b.a.a.g.a.p(new b.a.a.c.a(dVar, th));
            }
        }
    }

    a(b.a.a.a.g<t<T>> gVar) {
        this.f1771a = gVar;
    }

    @Override // b.a.a.a.g
    protected void t(i<? super T> iVar) {
        this.f1771a.a(new C0040a(iVar));
    }
}