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

IncrementalSyncWorkerImpl

internal class IncrementalSyncWorkerImpl(eventGatherer: EventGatherer, batchProcessor: EventBatchProcessor, logger: KaliumLogger = kaliumLogger, consumePendingAccountInvalidation: suspend () -> Boolean = { false }, consumePendingLegalHoldTransitions: suspend () -> Unit = {}, consumePendingConversationCleanup: suspend () -> Unit = {}) : IncrementalSyncWorker

Constructors

constructor(eventGatherer: EventGatherer, batchProcessor: EventBatchProcessor, logger: KaliumLogger = kaliumLogger, consumePendingAccountInvalidation: suspend () -> Boolean = { false }, consumePendingLegalHoldTransitions: suspend () -> Unit = {}, consumePendingConversationCleanup: suspend () -> Unit = {})

Types

Companion

object Companion

Functions

processEventsFlow

open suspend override fun processEventsFlow(): Flow<EventSource>

Collection starts receiving and processing, emitting the source of current events.