logic/com.wire.kalium.logic.sync.deferred/MainAppPendingDeliveryWorker

MainAppPendingDeliveryWorker

internal class MainAppPendingDeliveryWorker(pending: PendingDeliveryConfirmationDAO, conversations: ConversationRepository, sendDelivery: SendDeliverSignalUseCase, syncStateObserver: SyncStateObserver)

The NSE records work before completion; the owned app scope sends it after sync is live.

Constructors

Link copied to clipboard
constructor(pending: PendingDeliveryConfirmationDAO, conversations: ConversationRepository, sendDelivery: SendDeliverSignalUseCase, syncStateObserver: SyncStateObserver)

Functions

Link copied to clipboard
suspend fun drain(): Either<CoreFailure, Unit>

A failed item stays durable, while independent confirmations in later pages can advance.

Link copied to clipboard
suspend fun run()
Generated by Dokka
© 2026 Copyright