package f.a.w.e.d;

import java.util.Objects;
import java.util.concurrent.Callable;

/* JADX INFO: compiled from: ObservableError.java */
/* JADX INFO: loaded from: classes.dex */
public final class j<T> extends f.a.i<T> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Callable<? extends Throwable> f3810b;

    public j(Callable<? extends Throwable> callable) {
        this.f3810b = callable;
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        try {
            Throwable thCall = this.f3810b.call();
            Objects.requireNonNull(thCall, "Callable returned null throwable. Null values are generally not allowed in 2.x operators and sources.");
            th = thCall;
        } catch (Throwable th) {
            th = th;
            d.i.c.a.L(th);
        }
        f.a.w.a.c.error(th, nVar);
    }
}