Struct MockTransport 

pub struct MockTransport { /* private fields */ }

Mock transport for unit testing.

Records sent data and replays scripted responses from a queue. When the queue is empty and the transport is connected, recv will pend indefinitely — simulating a connected-but-idle transport. Call close to signal connection closure (returns None).

Implementations

impl MockTransport

pub fn new() -> Self

Create a new, disconnected mock transport.

pub fn script_recv(&mut self, data: Vec<u8>)

Queue a message to be returned by Transport::recv.

pub fn script_close_reason(&mut self, reason: impl Into<String>)

Script the reason the peer gives for closing, so a test can assert that it reaches the application rather than being swallowed.

pub fn take_sent(&mut self) -> Vec<Vec<u8>>

Take all sent data (for assertions). Drains the internal buffer.

Trait Implementations

impl Default for MockTransport

fn default() -> Self

Returns the “default value” for a type.

impl Transport for MockTransport

type Error = MockTransportError

The error type produced by this transport.

fn connect<'life0, 'life1, 'async_trait>( &'life0 mut self, _url: &'life1 str, _headers: Vec<(String, String)>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Connect to the given URL with optional headers.

fn send<'life0, 'async_trait>( &'life0 mut self, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Send raw bytes.

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, Self::Error>> + Send + 'async_trait>>

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

Receive raw bytes. Returns None when the connection is closed.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Close the transport.

fn close_reason(&self) -> Option<String>

Why the peer closed the connection, if it said.