Struct ReplayTransport 

pub struct ReplayTransport { /* private fields */ }

A Transport that replays recorded inbound frames and collects outbound frames. See the module docs for gating and drain semantics.

Implementations

impl ReplayTransport

pub fn from_frames(frames: Vec<Vec<u8>>) -> (Self, ReplayControl)

Build a replay transport from raw inbound frames.

The first frame should be the setupComplete handshake; it is delivered ungated so the connection can reach Active.

pub fn from_wire_log(entries: &[WireEntry]) -> (Self, ReplayControl)

Build a replay transport from a recorded wire log, keeping only the WireDirection::Inbound entries (in log order).

Each frame keeps its recorded capture time, reported to a with_frame_gate callback.

pub fn with_frame_gate(self, gate: FrameGate) -> Self

Pass each frame’s recorded capture time to gate and wait for it before delivering the frame. Frames built with from_frames carry no timestamps, so the gate is not called for them.

pub fn with_ungated_prefix(self, n: usize) -> Self

Override how many leading frames are delivered before ReplayControl::release (default 1: the setup handshake).

Trait Implementations

impl Transport for ReplayTransport

type Error = ReplayTransportError

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.