logic/com.wire.kalium.logic.sync/SendPendingAssetMessageUseCaseImpl

SendPendingAssetMessageUseCaseImpl

internal class SendPendingAssetMessageUseCaseImpl(assetRepository: AssetRepository, persistMessage: PersistMessageUseCase, updateAssetMessageTransferStatus: UpdateAssetMessageTransferStatusUseCase, getAssetMessageTransferStatus: GetAssetMessageTransferStatusUseCase, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, audioNormalizedLoudnessBuilder: AudioNormalizedLoudnessBuilder, pendingMessagesEnabled: Boolean = true, dispatchers: KaliumDispatcher = KaliumDispatcherImpl) : SendPendingAssetMessageUseCase

Constructors

SendPendingAssetMessageUseCaseImpl

constructor(assetRepository: AssetRepository, persistMessage: PersistMessageUseCase, updateAssetMessageTransferStatus: UpdateAssetMessageTransferStatusUseCase, getAssetMessageTransferStatus: GetAssetMessageTransferStatusUseCase, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, audioNormalizedLoudnessBuilder: AudioNormalizedLoudnessBuilder, pendingMessagesEnabled: Boolean = true, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Functions

open suspend operator override fun invoke(message: Message.Regular): Either<CoreFailure, Unit>