logic/com.wire.kalium.logic.sync/SyncExecutor

SyncExecutor

abstract class SyncExecutor

Inheritors

SyncExecutorImpl

Constructors

SyncExecutor

constructor()

Types

Request

internal inner class Request(syncStateFlow: StateFlow<SyncState>, job: Job, logger: KaliumLogger) : SyncRequest

Functions

request

abstract suspend fun <T> request(executorAction: suspend SyncRequest.() -> T): T

Requests Sync to be performed, fetching new events, etc. bringing the user to an online status. At the end of executorAction, the request is released.

startAndStopSyncAsNeeded

abstract fun startAndStopSyncAsNeeded()

stopForRestart

abstract suspend fun stopForRestart()

Permanently stops sync and waits for in-flight event processing to finish.