Kaptos/xyz.mcxross.kaptos.transaction/TransactionWorker

TransactionWorker

class TransactionWorker(scope: CoroutineScope, sequenceManager: AccountSequenceManager, capacity: Int = DEFAULT_CAPACITY, submitTransaction: suspend (UnsignedTransaction) -> AptosResult<PendingTransactionResponse>, isSequenceMismatch: (AptosError) -> Boolean = ::defaultSequenceMismatch)

Bounded, single-sender transaction pipeline.

The worker reserves sequence numbers only after dequeuing work, retries once after a recognized sequence mismatch, and never blocks callers from observing an individual submission result.

Constructors

TransactionWorker

constructor(scope: CoroutineScope, sequenceManager: AccountSequenceManager, capacity: Int = DEFAULT_CAPACITY, submitTransaction: suspend (UnsignedTransaction) -> AptosResult<PendingTransactionResponse>, isSequenceMismatch: (AptosError) -> Boolean = ::defaultSequenceMismatch)

Types

Companion

object Companion

Properties

events

val events: SharedFlow<TransactionWorkerEvent>

Hot stream of queue, build, submit, failure, cancellation, and drain events.

Functions

shutdown

suspend fun shutdown(mode: TransactionWorkerShutdown = TransactionWorkerShutdown.Drain)

Drains queued submissions or cancels them immediately, then waits for termination.

submit

suspend fun submit(build: suspend (sequenceNumber: ULong) -> AptosResult<UnsignedTransaction>): Deferred<AptosResult<PendingTransactionResponse>>

Queues a transaction factory and returns its independently awaitable result.