system/com.splendo.kaluga.system.network.state/BaseNetworkStateRepo

BaseNetworkStateRepo

abstract class BaseNetworkStateRepo(createNotInitializedState: () -> NetworkState.NotInitialized, createInitializingState: suspend ColdStateFlowRepo<NetworkState>.(NetworkState.Inactive) -> suspend () -> NetworkState, createDeinitializingState: suspend ColdStateFlowRepo<NetworkState>.(NetworkState.Active) -> suspend () -> NetworkState.Deinitialized, coroutineContext: CoroutineContext) : ColdStateFlowRepo<NetworkState>

An abstract ColdStateFlowRepo for managing NetworkState

Parameters

createNotInitializedState

method for creating the initial NetworkState.NotInitialized State

createInitializingState

method for transitioning from a NetworkState.Inactive into a NetworkState.Initializing given an implementation of this ColdStateFlowRepo

createDeinitializingState

method for transitioning from a NetworkState.Active into a NetworkState.Deinitialized given an implementation of this ColdStateFlowRepo

coroutineContext

the CoroutineContext the CoroutineContext used to create a coroutine scope for this state machine.

Inheritors

NetworkStateImplRepo

Constructors

BaseNetworkStateRepo

constructor(createNotInitializedState: () -> NetworkState.NotInitialized, createInitializingState: suspend ColdStateFlowRepo<NetworkState>.(NetworkState.Inactive) -> suspend () -> NetworkState, createDeinitializingState: suspend ColdStateFlowRepo<NetworkState>.(NetworkState.Active) -> suspend () -> NetworkState.Deinitialized, coroutineContext: CoroutineContext)

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

deinitChangeStateWithRepo

val deinitChangeStateWithRepo: suspend (NetworkState, ColdStateFlowRepo<NetworkState>) -> suspend () -> NetworkState?

val firstState: () -> NetworkState

initChangeStateWithRepo

val initChangeStateWithRepo: suspend (NetworkState, ColdStateFlowRepo<NetworkState>) -> suspend () -> NetworkState

lazyMutableFlow

open override val lazyMutableFlow: Lazy<MutableStateFlow<NetworkState>>

open override val stateFlow: StateFlow<NetworkState>

subscriptionCount

val subscriptionCount: StateFlow<Int>

Functions

open suspend override fun collect(collector: FlowCollector<NetworkState>): Nothing

firstCollection

open suspend override fun firstCollection()

suspend override fun initialValue(): NetworkState

laterCollections

open suspend override fun laterCollections(): NetworkState

launchTakeAndChangeState

fun launchTakeAndChangeState(context: CoroutineContext, action: suspend (NetworkState) -> suspend () -> NetworkState): Job

fun <K : NetworkState> launchTakeAndChangeState(context: CoroutineContext, remainIfStateNot: KClass<K>, action: suspend (K) -> suspend () -> NetworkState): Job

fun <Result> launchUseState(context: CoroutineContext, action: suspend (NetworkState) -> Result): Job

fun Flow<NetworkState>.network(): Flow<NetworkConnectionType>

Transforms a Flow of NetworkState into a flow of its associated NetworkConnectionType

noMoreCollections

suspend override fun noMoreCollections(): NetworkState

fun Flow<NetworkState>.online(): Flow<Boolean>

Transforms a Flow of NetworkState into a flow indicating the network is considered to be available.

fun peekState(): NetworkState

takeAndChangeState

suspend fun takeAndChangeState(action: suspend (NetworkState) -> suspend () -> NetworkState): NetworkState

suspend fun <K : NetworkState> takeAndChangeState(remainIfStateNot: KClass<K>, action: suspend (K) -> suspend () -> NetworkState): NetworkState

suspend fun <Result> useState(action: suspend (NetworkState) -> Result): Result