logic/com.wire.kalium.logic.sync.incremental/LiveSourceChangeHandlerImpl

LiveSourceChangeHandlerImpl

internal class LiveSourceChangeHandlerImpl(processingScope: <Error class: unknown class>) : LiveSourceChangeHandler

Constructors

constructor(processingScope: <Error class: unknown class>)

Types

Companion

object Companion

Functions

clear

open suspend override fun clear(): <Error class: unknown class>

Cancel the catching up job and reset the last time the websocket was opened and the last time an event was received.To be called when the websocket is closed.

scheduleNewCatchingUpJob

open suspend override fun scheduleNewCatchingUpJob(interval: <Error class: unknown class>, onEventIntervalGapReached: () -> Unit): <Error class: unknown class>

Schedule a new catching up job that will be cancelled if there was already one pending scheduled. Scheduled to run once with a delay of CATCHING_UP_JOB_EVENT_INTERVAL.

startNewCatchingUpJob

open suspend override fun startNewCatchingUpJob(interval: <Error class: unknown class>, onStartIntervalReached: () -> Unit): <Error class: unknown class>

Start the processing of the catching up job.

toString

open override fun toString(): String