logic/com.wire.kalium.logic.sync.receiver/FederationEventReceiverImpl

FederationEventReceiverImpl

internal class FederationEventReceiverImpl(conversationRepository: ConversationRepository, connectionRepository: ConnectionRepository, userRepository: UserRepository, memberDAO: MemberDAO, persistMessage: PersistMessageUseCase, selfUserId: UserId, dispatchers: KaliumDispatcher = KaliumDispatcherImpl) : FederationEventReceiver

Constructors

FederationEventReceiverImpl

internal constructor(conversationRepository: ConversationRepository, connectionRepository: ConnectionRepository, userRepository: UserRepository, memberDAO: MemberDAO, persistMessage: PersistMessageUseCase, selfUserId: UserId, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Types

internal object Companion

Functions

open suspend override fun onEvent(transactionContext: CryptoTransactionContext, event: Event.Federation, deliveryInfo: EventDeliveryInfo): Either<CoreFailure, Unit>