NewMessageEventHandlerImpl
internal class NewMessageEventHandlerImpl(proteusMessageUnpacker: ProteusMessageUnpacker, mlsMessageUnpacker: MLSMessageUnpacker, applicationMessageHandler: ApplicationMessageHandler, legalHoldHandler: LegalHoldHandler, enqueueSelfDeletion: (ConversationId, messageId: String) -> Unit, enqueueConfirmationDelivery: suspend (ConversationId, messageId: String) -> Unit, selfUserId: UserId, staleEpochVerifier: StaleEpochVerifier, resetMLSConversation: ResetMLSConversationUseCase, receiveRecovery: MLSReceiveRecoveryHandler? = null, bufferedMLSMessageRecoveryTracker: BufferedMLSMessageRecoveryTracker = BufferedMLSMessageRecoveryTracker()) : NewMessageEventHandler
Constructors
Link copied to clipboard
constructor(proteusMessageUnpacker: ProteusMessageUnpacker, mlsMessageUnpacker: MLSMessageUnpacker, applicationMessageHandler: ApplicationMessageHandler, legalHoldHandler: LegalHoldHandler, enqueueSelfDeletion: (ConversationId, messageId: String) -> Unit, enqueueConfirmationDelivery: suspend (ConversationId, messageId: String) -> Unit, selfUserId: UserId, staleEpochVerifier: StaleEpochVerifier, resetMLSConversation: ResetMLSConversationUseCase, receiveRecovery: MLSReceiveRecoveryHandler? = null, bufferedMLSMessageRecoveryTracker: BufferedMLSMessageRecoveryTracker = BufferedMLSMessageRecoveryTracker())
Functions
Link copied to clipboard
Link copied to clipboard
open suspend override fun handleNewMLSMessage(transactionContext: CryptoTransactionContext, event: Event.Conversation.NewMLSMessage, deliveryInfo: EventDeliveryInfo): Either<CoreFailure, Unit>
Link copied to clipboard
open suspend override fun handleNewProteusMessage(transactionContext: CryptoTransactionContext, event: Event.Conversation.NewMessage, deliveryInfo: EventDeliveryInfo)