Struct MemoryResponseChannel 

pub struct MemoryResponseChannel {
    pub sender: Sender<CanonicalMessage>,
    pub receiver: Receiver<CanonicalMessage>,
    /* private fields */
}

A shareable, thread-safe, in-memory channel for responses.

Fields

sender: Sender<CanonicalMessage>

receiver: Receiver<CanonicalMessage>

Implementations

impl MemoryResponseChannel

pub fn new(capacity: usize) -> Self

pub fn close(&self)

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub async fn wait_for_response(&self) -> Result<CanonicalMessage>

pub async fn register_waiter( &self, correlation_id: &str, sender: Sender<CanonicalMessage>, ) -> Result<()>

pub async fn remove_waiter( &self, correlation_id: &str, ) -> Option<Sender<CanonicalMessage>>

Trait Implementations

impl Clone for MemoryResponseChannel

fn clone(&self) -> MemoryResponseChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryResponseChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.