package j.i0.a;

import a.a.a.a.c.n0;
import d.a.h;
import d.a.l;
import j.b0;
import java.util.Objects;

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

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

    public static class a<R> implements l<b0<R>> {

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

        public a(l<? super d<R>> lVar) {
            this.f6914b = lVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            try {
                l<? super d<R>> lVar = this.f6914b;
                Objects.requireNonNull(th, "error == null");
                lVar.d(new d(null, th));
                this.f6914b.b();
            } catch (Throwable th2) {
                try {
                    this.f6914b.a(th2);
                } catch (Throwable th3) {
                    n0.y(th3);
                    d.a.u.a.v(new d.a.q.a(th2, th3));
                }
            }
        }

        @Override // d.a.l
        public void b() {
            this.f6914b.b();
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            this.f6914b.c(bVar);
        }

        @Override // d.a.l
        public void d(Object obj) {
            b0 b0Var = (b0) obj;
            l<? super d<R>> lVar = this.f6914b;
            Objects.requireNonNull(b0Var, "response == null");
            lVar.d(new d(b0Var, null));
        }
    }

    public e(h<b0<T>> hVar) {
        this.f6913b = hVar;
    }

    @Override // d.a.h
    public void o(l<? super d<T>> lVar) {
        this.f6913b.e(new a(lVar));
    }
}