package 㴹.K.Ԕ.ඓ.K;

import io.reactivex.internal.subscriptions.ScalarSubscription;
import 㳳.ʬ.AbstractC2397;
import 㴹.K.AbstractC2511;
import 㴹.K.Ԕ.ʬ.AbstractCallableC2437;

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

    /* renamed from: ʬ  reason: contains not printable characters */
    public final T f8400;

    public C2452(T t) {
        this.f8400 = t;
    }

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

    @Override // 㴹.K.AbstractC2511
    /* renamed from: K  reason: contains not printable characters */
    public void m6494(AbstractC2397<? super T> r3) {
        r3.onSubscribe(new ScalarSubscription(r3, this.f8400));
    }
}
