IncrementalSyncWorkerImpl

internal class IncrementalSyncWorkerImpl(eventGatherer: EventGatherer, eventProcessor: EventProcessor, logger: <Error class: unknown class> = kaliumLogger) : IncrementalSyncWorker

Constructors

constructor(eventGatherer: EventGatherer, eventProcessor: EventProcessor, logger: <Error class: unknown class> = kaliumLogger)

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

Upon collection, will start collecting and processing events, emitting the source of current events.