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

Package-level declarations

Types

internal data class ConversationTimeEventInput(val conversationId: ConversationId, val eventTime: Instant)

The input of a conversation time-event. Used to schedule ConversationTimeEventWork through the ConversationWorkQueue.

internal data class ConversationTimeEventWork(val conversationTimeEventInput: ConversationTimeEventInput, val worker: ConversationTimeEventWorker)

Represents a conversation time-event work, consisting of the input and the worker.

ConversationTimeEventWorker

internal fun interface ConversationTimeEventWorker

ConversationWorkQueue

internal fun interface ConversationWorkQueue

A work queue that schedules and runs actions for conversations based on a time

ParallelConversationWorkQueue

internal class ParallelConversationWorkQueue(scope: CoroutineScope, kaliumLogger: KaliumLogger, dispatcher: CoroutineDispatcher) : ConversationWorkQueue

This implementation of ConversationWorkQueue allows parallel work between conversations, but only one simultaneous work per conversation, i.e. each conversation has its own parallel queue.

SendConfirmationUseCase

internal interface SendConfirmationUseCase

This use case allows to send a confirmation type ReceiptType.READ

Functions

SendConfirmationUseCase

internal fun SendConfirmationUseCase(currentClientIdProvider: CurrentClientIdProvider, syncManager: SyncManager, messageSender: MessageSender, selfUserId: UserId, conversationRepository: ConversationRepository, messageRepository: MessageRepository, userPropertyRepository: UserPropertyRepository): SendConfirmationUseCase