TransactionQueue
Class to manage procedural transaction queues
Type parameters
▪ ReturnType
▪ TransactionArgs: unknown[][]
Hierarchy
TransactionQueue
Index
Constructors
Properties
Methods
Constructors
constructor
+ new TransactionQueue(transactions: PolymeshTransactionArray‹TransactionArgs›, returnValue: MaybePostTransactionValue‹ReturnType›, context: Context): TransactionQueue
Defined in src/base/TransactionQueue.ts:77
Create a transaction queue
Parameters:
Returns: TransactionQueue
Properties
Optional error
Optional error• error? : PolymeshError
Defined in src/base/TransactionQueue.ts:51
optional error information
status
• status: TransactionQueueStatus = TransactionQueueStatus.Idle
Defined in src/base/TransactionQueue.ts:46
status of the queue
transactions
• transactions: PolymeshTransactionArray‹TransactionArgs›
Defined in src/base/TransactionQueue.ts:41
transactions that will be run in the queue
Methods
getMinFees
▸ getMinFees(): Promise‹Fees›
Defined in src/base/TransactionQueue.ts:178
Retrieves a lower bound of the fees required to execute this transaction queue. Transaction fees can be higher at execution time for two reasons:
One or more transactions (or arguments) depend on the result of another transaction in the queue.
This means fees can't be calculated for said transaction until previous transactions in the queue have run
Protocol fees may vary between when this value is fetched and when the transaction is actually executed because of a
governance vote
note transaction fees that are paid by a third party aren't included in this total
Returns: Promise‹Fees›
onProcessedByMiddleware
▸ onProcessedByMiddleware(listener: function): function
Defined in src/base/TransactionQueue.ts:239
Subscribe to the results of this queue being processed by the harvester (and as such, available to the middleware)
note this event will be fired even if the queue fails
throws if the middleware wasn't enabled when instantiating the SDK client
Parameters:
▪ listener: function
callback function that will be called whenever the middleware is updated with the latest data. If there is an error (timeout or middleware offline) it will be passed to this callback
▸ (err?: PolymeshError): void
Parameters:
Returns: function
unsubscribe function
▸ (): void
onStatusChange
▸ onStatusChange(listener: function): function
Defined in src/base/TransactionQueue.ts:202
Subscribe to status changes on the Transaction Queue
Parameters:
▪ listener: function
callback function that will be called whenever the Transaction Queue's status changes
▸ (transactionQueue: this, err?: PolymeshError): void
Parameters:
Returns: function
unsubscribe function
▸ (): void
onTransactionStatusChange
▸ onTransactionStatusChange‹TxArgs, Values›(listener: function): function
Defined in src/base/TransactionQueue.ts:219
Subscribe to status changes on individual transactions
Type parameters:
▪ TxArgs: unknown[]
▪ Values: unknown[]
Parameters:
▪ listener: function
callback function that will be called whenever the individual transaction's status changes
▸ (transaction: PolymeshTransactionBase‹TxArgs, Values›, transactionQueue: this): void
Parameters:
Returns: function
unsubscribe function
▸ (): void
run
▸ run(): Promise‹ReturnType›
Defined in src/base/TransactionQueue.ts:112
Run the transactions in the queue in sequential order. If a transaction fails or the user refuses to sign it, one of two things can happen:
1) If transaction.isCritical === true, the entire queue fails and the corresponding error is stored in this.error as well as thrown 2) Otherwise, the queue continues executing and the error is stored in transaction.error
Returns: Promise‹ReturnType›
Last updated