logic/com.wire.kalium.logic.feature.asset.upload/TrackedAssetUploadImpl

TrackedAssetUploadImpl

internal class TrackedAssetUploadImpl(val messageId: String, scope: CoroutineScope, retryOperation: suspend () -> TrackedAssetUpload, monitor: suspend () -> Unit, upload: suspend () -> Either<CoreFailure, Unit>, onCancelled: suspend () -> Unit, onFailed: suspend (CoreFailure) -> Unit = {}) : TrackedAssetUpload

Constructors

constructor(messageId: String, scope: CoroutineScope, retryOperation: suspend () -> TrackedAssetUpload, monitor: suspend () -> Unit, upload: suspend () -> Either<CoreFailure, Unit>, onCancelled: suspend () -> Unit, onFailed: suspend (CoreFailure) -> Unit = {})

Properties

messageId

open override val messageId: String

operationId

open override val operationId: String

progress

open override val progress: StateFlow<AssetUploadProgress>

Functions

awaitCompletion

open suspend override fun awaitCompletion(): AssetUploadCompletion

Waits for upload, message send and monitor/cancellation cleanup. Cancelling the waiter does not cancel this operation.

cancel

open override fun cancel()

retry

open suspend override fun retry(): TrackedAssetUpload

Retries a failed/cancelled attempt with the same persisted message. Active and successful attempts return themselves.