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.

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.