Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Manages pending transactions, matching responses to requests by transactionId.

Implementations

impl TransactionManager

pub fn new() -> Self

pub async fn create( &self, transaction_type: TransactionType, ) -> (String, Receiver<Result<TransactionResult, String>>)

Create a new transaction, returning (transactionId, receiver). The receiver will get the result when the dylib responds. A timeout task is spawned that rejects after 120 seconds.

pub async fn resolve( &self, transaction_id: &str, identifier: &str, data: Option<Value>, )

Resolve a transaction with the dylib’s response.

pub async fn reject(&self, transaction_id: &str, error: &str)

Reject a transaction with an error message.

pub async fn is_pending(&self, transaction_id: &str) -> bool

Check if a transaction ID is pending.

pub async fn pending_count(&self) -> usize

Number of pending transactions.

Trait Implementations

impl Default for TransactionManager

fn default() -> Self

Returns the “default value” for a type.