SyncManagerImpl

internal class SyncManagerImpl(slowSyncRepository: SlowSyncRepository, incrementalSyncRepository: IncrementalSyncRepository, logger: <Error class: unknown class> = kaliumLogger) : SyncManager

Constructors

constructor(slowSyncRepository: SlowSyncRepository, incrementalSyncRepository: IncrementalSyncRepository, logger: <Error class: unknown class> = kaliumLogger)

open suspend override fun isSlowSyncCompleted(): Boolean

open suspend override fun isSlowSyncOngoing(): Boolean

open suspend override fun waitUntilLive()

Suspends the caller until all pending events are processed, and the client has finished processing all pending events.

If Sync is ongoing, suspends the caller until it reaches a terminal state.