pub async fn complete_outbound_transaction(
        &self,
        tx_id: TxId,
        transaction: CompletedTransaction,
    ) -> Result<(), TransactionStorageError>
    {
        let db_clone = self.db.clone();

        tokio::task::spawn_blocking(move || db_clone.complete_outbound_transaction(tx_id, transaction))
            .await
            .map_err(|err| TransactionStorageError::BlockingTaskSpawnError(err.to_string()))
            .and_then(|inner_result| inner_result)
    }
/// This method moves a `PendingOutboundTransaction` to the `CompleteTransaction` collection.
This method moves a `PendingOutboundTransaction` to the `CompleteTransaction` collection.
This method moves a ` PendingOutboundTransaction ` to the ` CompleteTransaction ` collection .
pub async fn complete_outbound_transaction(
        &self,
        tx_id: TxId,
        transaction: CompletedTransaction,
    ) -> Result<(), TransactionStorageError>
    {
        let db_clone = self.db.clone();
        tokio::task::spawn_blocking(move || db_clone.complete_outbound_transaction(tx_id, transaction))
            .await
            .map_err(|err| TransactionStorageError::BlockingTaskSpawnError(err.to_string()))
            .and_then(|inner_result| inner_result)
    }
pub async fn complete_outbound_transaction ( & self , tx_id : TxId , transaction : CompletedTransaction , ) -> Result < ( ) , TransactionStorageError > { let db_clone = self . db . clone ( ) ; tokio :: task :: spawn_blocking ( move | | db_clone . complete_outbound_transaction ( tx_id , transaction ) ) . await . map_err ( | err | TransactionStorageError :: BlockingTaskSpawnError ( err . to_string ( ) ) ) . and_then ( | inner_result | inner_result ) }
This method moves a `PendingOutboundTransaction` to the `CompleteTransaction` collection.
This method moves a ` PendingOutboundTransaction ` to the ` CompleteTransaction ` collection .
&self
tx_id
TxId
transaction
CompletedTransaction
&self
tx_id
TxId
transaction
CompletedTransaction