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.

Parameters

interval

The delay between each event processing. Default is CATCHING_UP_JOB_EVENT_INTERVAL.

onEventIntervalGapReached

The task to be executed when the time reached. Used to mark the status of fetching events as LIVE.