Struct MemTransportServer 

pub struct MemTransportServer { /* private fields */ }

An entirely in-process TransportServer used by the integration test harness.

Servers created by MemTransportFactory share a process-wide registry keyed by port; “sending a request” from one client to one server becomes a channel send on the registry. There is no serialization to sockets, no DNS, no kernel — which makes this both dramatically faster than a real network and fully deterministic when paired with a virtual crate::tools::time_provider::time_provider::TimeProvider. Port 0 is translated to a freshly-allocated port number, mirroring the semantics of a real OS bind.

Not for production use: there is nothing here that crosses a process or host boundary.

Trait Implementations

impl TransportServer for MemTransportServer

fn get_address(&self) -> &String

fn get_transport_ownership_proof(&self) -> Arc<dyn TransportOwnershipProof>

Returns the per-transport ownership-proof object used to (a) produce the proof bytes embedded in this server’s outbound AnnounceV2 requests and (b) verify proof bytes received from peers in inbound AnnounceV2 requests. The default reject-all implementation is overridden by transports that have a real notion of address ownership (HTTPS via ACME cert, mem-transport via an empty marker, …).

fn listen<'life0, 'async_trait>( &'life0 self, cancellation_token: CancellationToken, handler: Sender<IncomingRequest>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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