package d.a.s.e.c;

import a.a.a.a.c.n0;
import java.util.Objects;
import java.util.concurrent.Callable;

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final d.a.r.c<? super T, ? extends d.a.k<? extends R>> f5766c;

    public m(T t, d.a.r.c<? super T, ? extends d.a.k<? extends R>> cVar) {
        this.f5765b = t;
        this.f5766c = cVar;
    }

    @Override // d.a.h
    public void o(d.a.l<? super R> lVar) {
        try {
            d.a.k<? extends R> kVarA = this.f5766c.a(this.f5765b);
            Objects.requireNonNull(kVarA, "The mapper returned a null ObservableSource");
            d.a.k<? extends R> kVar = kVarA;
            if (!(kVar instanceof Callable)) {
                kVar.e(lVar);
                return;
            }
            try {
                Object objCall = ((Callable) kVar).call();
                if (objCall == null) {
                    d.a.s.a.c.complete(lVar);
                    return;
                }
                l lVar2 = new l(lVar, objCall);
                lVar.c(lVar2);
                lVar2.run();
            } catch (Throwable th) {
                n0.y(th);
                d.a.s.a.c.error(th, lVar);
            }
        } catch (Throwable th2) {
            d.a.s.a.c.error(th2, lVar);
        }
    }
}