bluetooth/test-client/com.splendo.kaluga.bluetooth.test.device/MockConnectableDeviceStateRepo

MockConnectableDeviceStateRepo

class MockConnectableDeviceStateRepo(mockConnectableDeviceManager: MockConnectableDeviceManager, coroutineContext: CoroutineContext) : BaseConnectableDeviceStateRepo

Constructors

constructor(mockConnectableDeviceManager: MockConnectableDeviceManager, coroutineContext: CoroutineContext)

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

initialState

val initialState: (HotStateFlowRepo<ConnectableDeviceState>) -> ConnectableDeviceState

lazyMutableSharedFlow

open override val lazyMutableSharedFlow: Lazy<MutableStateFlow<ConnectableDeviceState>>

stateFlow

open override val stateFlow: StateFlow<ConnectableDeviceState>

subscriptionCount

val subscriptionCount: StateFlow<Int>

Functions

collect

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

connectedMockClient

suspend fun CoroutineScope.connectedMockClient(builder: ServiceWrapperBuilder.() -> Unit): ConnectedMockClient

Connects a mock Bluetooth device exposing the service described by builder, discovers its services, and returns a ConnectedMockClient that keeps the device connected so reads and writes route end-to-end.

initialValue

suspend override fun initialValue(): ConnectableDeviceState

launchTakeAndChangeState

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

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

launchUseState

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

peekState

fun peekState(): ConnectableDeviceState

takeAndChangeState

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

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

useState

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