package j.q.a;

import j.m;

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

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

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

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

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

        @Override // e.a.m
        public void a() {
            this.f4418b.a();
        }

        @Override // e.a.m
        public void b(Throwable th) {
            try {
                this.f4418b.d(e.a(th));
                this.f4418b.a();
            } catch (Throwable th2) {
                try {
                    this.f4418b.b(th2);
                } catch (Throwable th3) {
                    e.a.s.b.b(th3);
                    e.a.w.a.p(new e.a.s.a(th2, th3));
                }
            }
        }

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

        @Override // e.a.m
        /* JADX INFO: renamed from: e, reason: merged with bridge method [inline-methods] */
        public void d(m<R> mVar) {
            this.f4418b.d(e.b(mVar));
        }
    }

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

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