package f.z.a;

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

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

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

    /* JADX INFO: compiled from: ResultObservable.java */
    private static class a<R> implements i<t<R>> {

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

        a(i<? super e<R>> iVar) {
            this.f1783b = iVar;
        }

        @Override // b.a.a.a.i
        public void a(Throwable th) {
            try {
                this.f1783b.d(e.a(th));
                this.f1783b.b();
            } catch (Throwable th2) {
                try {
                    this.f1783b.a(th2);
                } catch (Throwable th3) {
                    b.a.a.c.b.a(th3);
                    b.a.a.g.a.p(new b.a.a.c.a(th2, th3));
                }
            }
        }

        @Override // b.a.a.a.i
        public void b() {
            this.f1783b.b();
        }

        @Override // b.a.a.a.i
        public void c(b.a.a.b.b bVar) {
            this.f1783b.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) {
            this.f1783b.d(e.b(tVar));
        }
    }

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

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