trixnity-client/de.connect2x.trixnity.client/CurrentSyncState

CurrentSyncState

class CurrentSyncState(currentSyncState: StateFlow<SyncState>) : StateFlow<SyncState>

Constructors

CurrentSyncState

constructor(currentSyncState: StateFlow<SyncState>)

constructor(api: MatrixClientServerApiClient)

Properties

replayCache

open override val replayCache: List<SyncState>

value

open override val value: SyncState

Functions

collect

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

firstWithContent

suspend fun Flow<TimelineEvent?>.firstWithContent(): TimelineEvent

flatten

@JvmName(name = "flattenList")

inline fun <V> Flow<List<Flow<V?>>>.flatten(throttle: Duration = 200.milliseconds): Flow<List<V>>

fun <K, V> Flow<Map<K, Flow<V?>>>.flatten(throttle: Duration = 200.milliseconds): Flow<Map<K, V?>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

flattenNotNull

fun <K, V> Flow<Map<K, Flow<V?>>>.flattenNotNull(throttle: Duration = 200.milliseconds): Flow<Map<K, V>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

flattenValues

inline fun <K, V> Flow<Map<K, Flow<V?>>>.flattenValues(throttle: Duration = 200.milliseconds): Flow<List<V>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

fun Flow<Map<RoomId, Flow<Room?>>>.flattenValues(throttle: Duration = 200.milliseconds, filterUpgradedRooms: Boolean = true): Flow<Set<Room>>

This collects all rooms, so when one changes, a new set gets emitted. A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

retry

suspend fun <T> StateFlow<SyncState>.retry(delayConfigWhenSyncRunning: RetryFlowDelayConfig = RetryFlowDelayConfig().copy(scheduleLimit = 10.seconds), delayConfigWhenSyncNotRunning: RetryFlowDelayConfig = RetryFlowDelayConfig(), onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend () -> T): T

retryFlow

fun <T> StateFlow<SyncState>.retryFlow(delayConfigWhenSyncRunning: RetryFlowDelayConfig = RetryFlowDelayConfig().copy(scheduleLimit = 10.seconds), delayConfigWhenSyncNotRunning: RetryFlowDelayConfig = RetryFlowDelayConfig(), onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend FlowCollector<T>.() -> Unit): Flow<T>

retryLoop

suspend fun StateFlow<SyncState>.retryLoop(delayConfigWhenSyncRunning: RetryFlowDelayConfig = RetryFlowDelayConfig().copy(scheduleLimit = 10.seconds), delayConfigWhenSyncNotRunning: RetryFlowDelayConfig = RetryFlowDelayConfig(), onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend () -> Unit)

toFlowList

@JvmName(name = "toList")

fun Flow<Flow<TimelineEvent>>.toFlowList(maxSize: StateFlow<Int>, minSize: MutableStateFlow<Int> = MutableStateFlow(0)): Flow<List<Flow<TimelineEvent>>>

Converts a flow of timeline events into a flow of list of timeline events limited by maxSize.

@JvmName(name = "toListFromLatest")

fun Flow<Flow<Flow<TimelineEvent>>?>.toFlowList(maxSize: StateFlow<Int>, minSize: MutableStateFlow<Int> = MutableStateFlow(0)): Flow<List<Flow<TimelineEvent>>>

Converts a flow of flows of timeline event into a flow of list of timeline events limited by maxSize.