logic/com.wire.kalium.logic.sync/SyncExecutorImpl

SyncExecutorImpl

internal class SyncExecutorImpl(syncStateObserver: SyncStateObserver, slowSyncManager: SlowSyncManager, incrementalSyncManager: IncrementalSyncManager, scope: CoroutineScope, shutdownCoordinator: SyncShutdownCoordinator = SyncShutdownCoordinator(), userScopedLogger: KaliumLogger = kaliumLogger) : SyncExecutor

Constructors

SyncExecutorImpl

constructor(syncStateObserver: SyncStateObserver, slowSyncManager: SlowSyncManager, incrementalSyncManager: IncrementalSyncManager, scope: CoroutineScope, shutdownCoordinator: SyncShutdownCoordinator = SyncShutdownCoordinator(), userScopedLogger: KaliumLogger = kaliumLogger)

Functions

request

open suspend override fun <T> request(requestAction: 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

open override fun startAndStopSyncAsNeeded()

stopForRestart

open suspend override fun stopForRestart()

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