kone.state/dev.lounres.kone.hub/KoneAsynchronousHub

KoneAsynchronousHub

interface KoneAsynchronousHub<out Value>(source)

Inheritors

KoneMutableAsynchronousHub

Types

fun interface Subscription

Properties

abstract val callbacksValue: Value

val <Value> KoneAsynchronousHub<Value>.value: Value

Functions

buildSubscriptionAtomic

inline fun <Value, Result> KoneAsynchronousHub<Value>.buildSubscriptionAtomic(valueEquality: Equality<Value> = Equality.absoluteFor(), builder: KoneAsynchronousHubAtomicSubscriptionScope<Value>.(Value) -> Result): Result

buildSubscriptionLocking

inline fun <Value, Result> KoneAsynchronousHub<Value>.buildSubscriptionLocking(builder: KoneAsynchronousHubBlockingSubscriptionScope<Value>.(Value) -> Result): Result

lockCallbacksValue

abstract fun lockCallbacksValue()

fun <Value, Result> KoneAsynchronousHub<Value>.map(valueEquality: Equality<Value> = Equality.absoluteFor(), transform: (Value) -> Result): KoneMutableAsynchronousHub<Result>

@IgnorableReturnValue

abstract fun subscribe(callback: suspend (Value) -> Unit): KoneAsynchronousHub.Subscription

fun <Value> KoneAsynchronousHub<Value>.toStateFlow(): StateFlow<Value>

unlockCallbacksValue

abstract fun unlockCallbacksValue()

inline fun <SourceValue, TargetValue> KoneAsynchronousHub<SourceValue>.view(crossinline get: (SourceValue) -> TargetValue): KoneAsynchronousHub<TargetValue>