logic/com.wire.kalium.logic.feature.message.receipt/ParallelConversationWorkQueue/enqueue

enqueue

open override fun enqueue(input: ConversationTimeEventInput, worker: ConversationTimeEventWorker)

Enqueues new work parameters for the provided input. Will only emit a new entry / replacing an existing one for the ConversationTimeEventInput.conversationId if the ConversationTimeEventInput.eventTime is more recent than the existing one. If there's an existing work being done for the same ConversationTimeEventInput.conversationId, it will wait until it's over. After that, will start working as soon as the dispatcher allows it, while the scope is alive.