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

Package-level declarations

Types

internal data class ConversationTimeEventInput(val conversationId: <Error class: unknown class>, val eventTime: <Error class: unknown class>)

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

ConversationTimeEventWork

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: <Error class: unknown class>, kaliumLogger: <Error class: unknown class>, dispatcher: <Error class: unknown class>) : 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: <Error class: unknown class>, conversationRepository: ConversationRepository, messageRepository: MessageRepository, userPropertyRepository: UserPropertyRepository): SendConfirmationUseCase