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