package l.h0.a;

import f.a.i;
import f.a.n;
import java.util.Objects;
import l.b0;

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

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

    /* JADX INFO: compiled from: ResultObservable.java */
    public static class a<R> implements n<b0<R>> {

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

        public a(n<? super d<R>> nVar) {
            this.f5026b = nVar;
        }

        @Override // f.a.n
        public void a(Throwable th) {
            try {
                n<? super d<R>> nVar = this.f5026b;
                Objects.requireNonNull(th, "error == null");
                nVar.c(new d(null, th));
                this.f5026b.onComplete();
            } catch (Throwable th2) {
                try {
                    this.f5026b.a(th2);
                } catch (Throwable th3) {
                    d.i.c.a.L(th3);
                    f.a.y.a.C0(new f.a.u.a(th2, th3));
                }
            }
        }

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

        @Override // f.a.n
        public void c(Object obj) {
            b0 b0Var = (b0) obj;
            n<? super d<R>> nVar = this.f5026b;
            Objects.requireNonNull(b0Var, "response == null");
            nVar.c(new d(b0Var, null));
        }

        @Override // f.a.n
        public void onComplete() {
            this.f5026b.onComplete();
        }
    }

    public e(i<b0<T>> iVar) {
        this.f5025b = iVar;
    }

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