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

LiveSourceChangeHandler

Handles the change of the event source from pending to live after opening a Websocket connection. It is used to manage the catching up job that processes events when the websocket is opened to mimic the behavior of the old quick sync that was used to fetch pending events from the notification stream.

Inheritors

LiveSourceChangeHandlerImpl

Functions

clear

abstract suspend fun clear()

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

abstract suspend fun scheduleNewCatchingUpJob(interval: <Error class: unknown class> = CATCHING_UP_JOB_EVENT_INTERVAL, onEventIntervalGapReached: () -> Unit)

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

abstract suspend fun startNewCatchingUpJob(interval: <Error class: unknown class> = CATCHING_UP_JOB_INITIAL_THRESHOLD, onStartIntervalReached: () -> Unit)

Start the processing of the catching up job.