package 㴹.K.Ԕ.ඓ.ῲ;

import io.reactivex.internal.disposables.EmptyDisposable;
import io.reactivex.internal.operators.observable.ObservableScalarXMap$ScalarDisposable;
import java.util.concurrent.Callable;
import ඓ.ⁱ.K.ඓ.C1252;
import 㴹.K.AbstractC2500;
import 㴹.K.AbstractC2518;
import 㴹.K.AbstractC2520;
import 㴹.K.Ԕ.ῲ.C2456;
import 㴹.K.䁗.AbstractC2521;

/* renamed from: 㴹.K.Ԕ.ඓ.ῲ.ⁱ  reason: contains not printable characters */
/* compiled from: ObservableScalarXMap */
public final class C2444<T, R> extends AbstractC2500<R> {

    /* renamed from: ʬ  reason: contains not printable characters */
    public final AbstractC2521<? super T, ? extends AbstractC2518<? extends R>> f8386;

    /* renamed from: ῲ  reason: contains not printable characters */
    public final T f8387;

    public C2444(T t, AbstractC2521<? super T, ? extends AbstractC2518<? extends R>> r2) {
        this.f8387 = t;
        this.f8386 = r2;
    }

    @Override // 㴹.K.AbstractC2500
    /* renamed from: ῲ  reason: contains not printable characters */
    public void m6489(AbstractC2520<? super R> r3) {
        try {
            Object apply = this.f8386.apply(this.f8387);
            C2456.m6500(apply, "The mapper returned a null ObservableSource");
            AbstractC2518 r0 = (AbstractC2518) apply;
            if (r0 instanceof Callable) {
                try {
                    Object call = ((Callable) r0).call();
                    if (call == null) {
                        EmptyDisposable.complete(r3);
                        return;
                    }
                    ObservableScalarXMap$ScalarDisposable observableScalarXMap$ScalarDisposable = new ObservableScalarXMap$ScalarDisposable(r3, call);
                    r3.onSubscribe(observableScalarXMap$ScalarDisposable);
                    observableScalarXMap$ScalarDisposable.run();
                } catch (Throwable th) {
                    C1252.m3329(th);
                    EmptyDisposable.error(th, r3);
                }
            } else {
                ((AbstractC2500) r0).m6545((AbstractC2520) r3);
            }
        } catch (Throwable th2) {
            EmptyDisposable.error(th2, r3);
        }
    }
}
