Struct InMemoryEndpoint 

pub struct InMemoryEndpoint { /* private fields */ }

An in-memory FIFO endpoint for quick testing.

Internally uses a VecDeque protected by a mutex (std::sync::Mutex or tokio::sync::Mutex for async mode). No backpressure, size limits, or correlation semantics are provided—this is intentionally minimal.

Implementations

impl InMemoryEndpoint

pub fn id(&self) -> &str

Get the ID of the endpoint.

pub fn source(&self) -> Option<&EndpointSource>

pub fn channel(&self) -> Option<&Arc<dyn Channel>>

Trait Implementations

impl Clone for InMemoryEndpoint

fn clone(&self) -> InMemoryEndpoint

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InMemoryEndpoint

fn default() -> InMemoryEndpoint

Returns the “default value” for a type.

impl Endpoint for InMemoryEndpoint

fn id(&self) -> &str

Stable identifier for this endpoint instance.

fn send( &self, exchange: Exchange, ) -> impl Future<Output = Result<(), Error>> + Send

Enqueue of an Exchange.

fn try_receive(&self) -> impl Future<Output = Option<Exchange>> + Send

Non-blocking dequeue of next Exchange.