package 㴹.K.Ԕ.ඓ.ῲ;

import io.reactivex.internal.operators.observable.ObservableScalarXMap$ScalarDisposable;
import 㴹.K.AbstractC2500;
import 㴹.K.AbstractC2520;
import 㴹.K.Ԕ.ʬ.AbstractCallableC2437;

/* renamed from: 㴹.K.Ԕ.ඓ.ῲ.㴹  reason: contains not printable characters */
/* compiled from: ObservableJust */
public final class C2446<T> extends AbstractC2500<T> implements AbstractCallableC2437<T> {

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

    public C2446(T t) {
        this.f8389 = t;
    }

    @Override // 㴹.K.Ԕ.ʬ.AbstractCallableC2437, java.util.concurrent.Callable
    public T call() {
        return this.f8389;
    }

    @Override // 㴹.K.AbstractC2500
    /* renamed from: ῲ  reason: contains not printable characters */
    public void m6490(AbstractC2520<? super T> r3) {
        ObservableScalarXMap$ScalarDisposable observableScalarXMap$ScalarDisposable = new ObservableScalarXMap$ScalarDisposable(r3, this.f8389);
        r3.onSubscribe(observableScalarXMap$ScalarDisposable);
        observableScalarXMap$ScalarDisposable.run();
    }
}
