logic/com.wire.kalium.logic.sync/SyncStateObserverImpl

SyncStateObserverImpl

internal class SyncStateObserverImpl(slowSyncRepository: SlowSyncRepository, incrementalSyncRepository: IncrementalSyncRepository, syncScope: <Error class: unknown class>, logger: <Error class: unknown class> = kaliumLogger) : SyncStateObserver

Constructors

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

Properties

syncState

open override val syncState: <Error class: unknown class>

Allows observing of SyncState. A value is always available immediately for new observers. Assumes that old SyncStates are not relevant anymore, so the available Flow has a limited buffer size and will drop the oldest values as there's no point in waiting for slow collectors. In case a slow collector is interested in receiving all values, it should add a buffer of its own.

Functions

isSlowSyncCompleted

open suspend override fun isSlowSyncCompleted(): Boolean

isSlowSyncOngoing

open suspend override fun isSlowSyncOngoing(): Boolean

waitUntilLive

open suspend override fun waitUntilLive()

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

waitUntilLiveOrFailure

open suspend override fun waitUntilLiveOrFailure(): <Error class: unknown class><<Error class: unknown class>, Unit>

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

waitUntilStartedOrFailure

open suspend override fun waitUntilStartedOrFailure(): <Error class: unknown class><<Error class: unknown class>, Unit>