KState/ca.acendas.kstate.utils/ThreadSafeStateContainer

ThreadSafeStateContainer

class ThreadSafeStateContainer<T> : StateContainer<T>

Thread-safe wrapper for StateContainer implementations.

This wrapper adds an additional layer of synchronization to any StateContainer, ensuring thread safety even if the underlying implementation is not thread-safe. Note that ImmutableStateContainer is already thread-safe, but this wrapper can be useful for other implementations or for additional guarantees.

Parameters

T

The type of state being managed

Types

object Companion

Properties

open override val currentState: T

The current state of the container.

Functions

fun <T> StateContainer<T>.compareAndSet(expectedState: T, newState: T): Boolean

Conditionally updates the state only if the current state matches the expected state.

fun <T> StateContainer<T>.getAndUpdate(updater: (T) -> T): T?

Updates the state and returns the previous state if successful, or null if failed.

inline fun <T, R : T> StateContainer<T>.getStateAs(): R?

Returns the current state cast to the specified type, or null if not of that type.

fun <T> StateContainer<T>.isState(predicate: (T) -> Boolean): Boolean

Checks if the state matches a predicate.

inline fun <T, R : T> StateContainer<T>.isStateType(): Boolean

Returns true if the current state is of the specified type.

fun <T, R> StateContainer<T>.map(mapper: (T) -> R): R

Maps the current state to a different type.

fun <T> StateContainer<T>.trySet(newState: T): Boolean

Attempts to set the state to a specific value.

fun <T> StateContainer<T>.updateAndGet(updater: (T) -> T): T?

Updates the state and returns the new state if successful, or null if failed.

fun <T> StateContainer<T>.updateAtomic(maxRetries: Int = 10, updater: (T) -> T): StateUpdateResult<T>

Extension function for StateContainer to perform atomic updates.

open override fun updateState(updater: (T) -> T): StateUpdateResult<T>

Updates the state using the provided updater function.

updateSuspending

suspend fun <T> StateContainer<T>.updateSuspending(updater: suspend (T) -> T): StateUpdateResult<T>

Transforms the state using a suspending function while maintaining thread safety.

open override fun validateState(state: T): ValidationResult

Validates the given state using the container's validator.

fun <T> StateContainer<T>.withState(action: (T) -> Unit)

Executes an action with the current state.