kone.state/dev.lounres.kone.hub/KoneBlockingHub

KoneBlockingHub

interface KoneBlockingHub<out Value>(source)

Inheritors

KoneMutableBlockingHub

Types

fun interface Subscription

Properties

abstract val callbacksValue: Value

val <Value> KoneBlockingHub<Value>.value: Value

Functions

buildSubscriptionAtomic

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

buildSubscriptionLocking

inline fun <Value, Result> KoneBlockingHub<Value>.buildSubscriptionLocking(builder: KoneBlockingHubBlockingSubscriptionScope<Value>.(Value) -> Result): Result

lockCallbacksValue

abstract fun lockCallbacksValue()

fun <Value, Result> KoneBlockingHub<Value>.map(valueEquality: Equality<Value> = Equality.defaultFor(), transform: (Value) -> Result): KoneMutableBlockingHub<Result>

@IgnorableReturnValue

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

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

unlockCallbacksValue

abstract fun unlockCallbacksValue()

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