package f.a.w.e.d;

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Callable<? extends f.a.l<? extends T>> f3775b;

    public d(Callable<? extends f.a.l<? extends T>> callable) {
        this.f3775b = callable;
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        try {
            f.a.l<? extends T> lVarCall = this.f3775b.call();
            Objects.requireNonNull(lVarCall, "null ObservableSource supplied");
            lVarCall.d(nVar);
        } catch (Throwable th) {
            d.i.c.a.L(th);
            f.a.w.a.c.error(th, nVar);
        }
    }
}