SyncApiClientImpl

class SyncApiClientImpl(baseClient: MatrixClientServerApiBaseClient, coroutineScope: CoroutineScope, syncBatchTokenStore: SyncBatchTokenStore, syncErrorDelayConfig: RetryFlowDelayConfig) : ClientEventEmitterImpl<SyncEvents> , SyncApiClient

Constructors

Link copied to clipboard
constructor(baseClient: MatrixClientServerApiBaseClient, coroutineScope: CoroutineScope, syncBatchTokenStore: SyncBatchTokenStore, syncErrorDelayConfig: RetryFlowDelayConfig)

Properties

Link copied to clipboard
open override val currentSyncState: StateFlow<SyncState>

Functions

Link copied to clipboard
open suspend override fun cancel()
Link copied to clipboard
open suspend override fun emit(events: SyncEvents)
Link copied to clipboard
open suspend override fun start(filter: String?, setPresence: Presence?, timeout: Duration)
Link copied to clipboard
open suspend override fun <T> startOnce(filter: String?, setPresence: Presence?, timeout: Duration, runOnce: suspend (SyncEvents) -> T): Result<T>
Link copied to clipboard
suspend fun SyncApiClient.startOnce(filter: String? = null, setPresence: Presence? = null, timeout: Duration = ZERO): Result<Unit>
Link copied to clipboard
open suspend override fun stop()
Link copied to clipboard
open override fun subscribe(priority: Int, subscriber: Subscriber<SyncEvents>): Unsubscriber
Link copied to clipboard
open suspend override fun sync(filter: String?, since: String?, fullState: Boolean, setPresence: Presence?, timeout: Duration, useStateAfter: Boolean?): Result<Sync.Response>

This is the plain sync request. If you want to subscribe to events and more, use start or startOnce.