Struct WalletWireProcessor 

pub struct WalletWireProcessor<W: WalletInterface> { /* private fields */ }

Receives wire protocol messages and dispatches them to a wallet implementation.

Implementations

impl<W: WalletInterface> WalletWireProcessor<W>

pub fn new(wallet: W) -> Self

Create a new processor wrapping a wallet implementation.

pub async fn process(&self, message: &[u8]) -> Vec<u8>

Process a raw wire message: parse frame, dispatch, return result frame.

Trait Implementations

impl<W: WalletInterface + Send + Sync> WalletWire for WalletWireProcessor<W>

WalletWireProcessor also implements WalletWire so it can serve as an in-memory transport for testing (transceiver -> processor -> wallet).

fn transmit_to_wallet<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, WalletError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a binary message to the wallet and receive the response.