kone.state/dev.lounres.kone.hub

Package-level declarations

Types

InternalKoneHubApi

@Target(allowedTargets = [AnnotationTarget.FUNCTION, AnnotationTarget.PROPERTY, AnnotationTarget.CLASS])

@RequiresOptIn(level = RequiresOptIn.Level.WARNING, message = "This is primitive internal automaton API. Use with caution.")

annotation class InternalKoneHubApi

KoneAsynchronousHub

interface KoneAsynchronousHub<out Value>

KoneAsynchronousHubAtomicSubscriptionScope

class KoneAsynchronousHubAtomicSubscriptionScope<out Value>

KoneAsynchronousHubBlockingSubscriptionScope

value class KoneAsynchronousHubBlockingSubscriptionScope<out Value>

KoneBlockingHub

interface KoneBlockingHub<out Value>

KoneBlockingHubAtomicSubscriptionScope

class KoneBlockingHubAtomicSubscriptionScope<out Value>

KoneBlockingHubBlockingSubscriptionScope

value class KoneBlockingHubBlockingSubscriptionScope<out Value>

KoneMutableAsynchronousHub

interface KoneMutableAsynchronousHub<Value> : KoneAsynchronousHub<Value>

KoneMutableBlockingHub

interface KoneMutableBlockingHub<Value> : KoneBlockingHub<Value>

Properties

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

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

Functions

fun <Value> KoneMutableAsynchronousHub.Companion.acceptingNew(initialValue: Value, valueEquality: Equality<Value> = Equality.defaultFor()): KoneMutableAsynchronousHub<Value>

fun <Value> KoneMutableBlockingHub.Companion.acceptingNew(initialValue: Value, valueEquality: Equality<Value> = Equality.defaultFor()): KoneMutableBlockingHub<Value>

buildSubscriptionAtomic

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

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

buildSubscriptionLocking

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

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

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.getAndUpdate(transform: (Value) -> Value): Value

inline fun <Value> KoneMutableBlockingHub<Value>.getAndUpdate(transform: (Value) -> Value): Value

KoneMutableAsynchronousHub

fun <Value> KoneMutableAsynchronousHub(initialValue: Value): KoneMutableAsynchronousHub<Value>

KoneMutableBlockingHub

fun <Value> KoneMutableBlockingHub(initialValue: Value): KoneMutableBlockingHub<Value>

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

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

suspend fun <Value> KoneMutableAsynchronousHub<Value>.set(newValue: Value)

fun <Value> KoneMutableBlockingHub<Value>.set(newValue: Value)

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

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

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.update(transform: (Value) -> Value)

inline fun <Value> KoneMutableBlockingHub<Value>.update(transform: (Value) -> Value)

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.updateAndGet(transform: (Value) -> Value): Value

inline fun <Value> KoneMutableBlockingHub<Value>.updateAndGet(transform: (Value) -> Value): Value

inline suspend fun <Value, Result> KoneMutableAsynchronousHub<Value>.updateAndMap(transform: (Value) -> Value, map: (Value, Value) -> Result): Result

inline fun <Value, Result> KoneMutableBlockingHub<Value>.updateAndMap(transform: (Value) -> Value, map: (Value, Value) -> Result): Result

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

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

inline fun <SourceValue, TargetValue> KoneMutableAsynchronousHub<SourceValue>.view(crossinline get: (SourceValue) -> TargetValue, crossinline set: suspend (previousSourceValue: SourceValue, newTargetValue: TargetValue) -> SourceValue): KoneMutableAsynchronousHub<TargetValue>

inline fun <SourceValue, TargetValue> KoneMutableBlockingHub<SourceValue>.view(crossinline get: (SourceValue) -> TargetValue, crossinline set: (previousSourceValue: SourceValue, newTargetValue: TargetValue) -> SourceValue): KoneMutableBlockingHub<TargetValue>