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

NetworkStateRepo

class NetworkStateRepo(networkManagerBuilder: NetworkManager.Builder, coroutineContext: CoroutineContext) : NetworkStateImplRepo

A NetworkStateImplRepo using a NetworkManager

Parameters

networkManagerBuilder

the NetworkManager.Builder for building a NetworkManager

coroutineContext

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

Constructors

NetworkStateRepo

constructor(networkManagerBuilder: NetworkManager.Builder, 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