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

IncrementalSyncWorkerImpl

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

Constructors

Link copied to clipboard
constructor(eventGatherer: EventGatherer, eventProcessor: EventProcessor, transactionProvider: CryptoTransactionProvider, logger: <Error class: unknown class> = kaliumLogger)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open suspend override fun processEventsFlow(): <Error class: unknown class><EventSource>

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