package f.a.w.e.d;

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

/* JADX INFO: compiled from: ObservableScalarXMap.java */
/* JADX INFO: loaded from: classes.dex */
public final class c0<T, R> extends f.a.i<R> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final T f3773b;

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

    public c0(T t, f.a.v.d<? super T, ? extends f.a.l<? extends R>> dVar) {
        this.f3773b = t;
        this.f3774e = dVar;
    }

    @Override // f.a.i
    public void v(f.a.n<? super R> nVar) {
        try {
            f.a.l<? extends R> lVarApply = this.f3774e.apply(this.f3773b);
            Objects.requireNonNull(lVarApply, "The mapper returned a null ObservableSource");
            f.a.l<? extends R> lVar = lVarApply;
            if (!(lVar instanceof Callable)) {
                lVar.d(nVar);
                return;
            }
            try {
                Object objCall = ((Callable) lVar).call();
                if (objCall == null) {
                    f.a.w.a.c.complete(nVar);
                    return;
                }
                b0 b0Var = new b0(nVar, objCall);
                nVar.b(b0Var);
                b0Var.run();
            } catch (Throwable th) {
                d.i.c.a.L(th);
                f.a.w.a.c.error(th, nVar);
            }
        } catch (Throwable th2) {
            f.a.w.a.c.error(th2, nVar);
        }
    }
}