Trait Endpoint 

pub trait Endpoint: Send + Sync {
    // Required methods
    fn id(&self) -> &str;
    fn send(
        &self,
        exchange: Exchange,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn try_receive(&self) -> impl Future<Output = Option<Exchange>> + Send;
}

A trait representing a message endpoint for sending and receiving Exchange objects.

Required Methods

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.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Endpoint for InMemoryInOnlyEndpoint

impl Endpoint for InMemoryEndpoint