package f.a.w.e.d;

import java.util.Objects;

/* JADX INFO: compiled from: ObservableOnErrorNext.java */
/* JADX INFO: loaded from: classes.dex */
public final class u<T> extends f.a.w.e.d.a<T, T> {

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final f.a.v.d<? super Throwable, ? extends f.a.l<? extends T>> f3882e;

    /* JADX INFO: compiled from: ObservableOnErrorNext.java */
    public static final class a<T> implements f.a.n<T> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final f.a.n<? super T> f3883b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final f.a.v.d<? super Throwable, ? extends f.a.l<? extends T>> f3884e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final f.a.w.a.f f3885f = new f.a.w.a.f();

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public boolean f3886g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public boolean f3887h;

        public a(f.a.n<? super T> nVar, f.a.v.d<? super Throwable, ? extends f.a.l<? extends T>> dVar, boolean z) {
            this.f3883b = nVar;
            this.f3884e = dVar;
        }

        @Override // f.a.n
        public void a(Throwable th) {
            if (this.f3886g) {
                if (this.f3887h) {
                    f.a.y.a.C0(th);
                    return;
                } else {
                    this.f3883b.a(th);
                    return;
                }
            }
            this.f3886g = true;
            try {
                f.a.l<? extends T> lVarApply = this.f3884e.apply(th);
                if (lVarApply != null) {
                    lVarApply.d(this);
                    return;
                }
                NullPointerException nullPointerException = new NullPointerException("Observable is null");
                nullPointerException.initCause(th);
                this.f3883b.a(nullPointerException);
            } catch (Throwable th2) {
                d.i.c.a.L(th2);
                this.f3883b.a(new f.a.u.a(th, th2));
            }
        }

        @Override // f.a.n
        public void b(f.a.t.b bVar) {
            f.a.w.a.f fVar = this.f3885f;
            Objects.requireNonNull(fVar);
            f.a.w.a.b.replace(fVar, bVar);
        }

        @Override // f.a.n
        public void c(T t) {
            if (this.f3887h) {
                return;
            }
            this.f3883b.c(t);
        }

        @Override // f.a.n
        public void onComplete() {
            if (this.f3887h) {
                return;
            }
            this.f3887h = true;
            this.f3886g = true;
            this.f3883b.onComplete();
        }
    }

    public u(f.a.l<T> lVar, f.a.v.d<? super Throwable, ? extends f.a.l<? extends T>> dVar, boolean z) {
        super(lVar);
        this.f3882e = dVar;
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        a aVar = new a(nVar, this.f3882e, false);
        nVar.b(aVar.f3885f);
        this.f3744b.d(aVar);
    }
}