logic/com.wire.kalium.logic.sync.incremental/IncrementalSyncWorker/processEventsWhilePolicyAllowsFlow

processEventsWhilePolicyAllowsFlow

abstract suspend fun processEventsWhilePolicyAllowsFlow(): <Error class: unknown class><EventSource>

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

Flow will finish only if the ConnectionPolicy is ConnectionPolicy.DISCONNECT_AFTER_PENDING_EVENTS. Otherwise, it will keep collecting and processing events indeterminately until a failure or cancellation.