Struct ChannelRegistry 

pub struct ChannelRegistry { /* private fields */ }

Thread-safe collection of named channel adapters.

Implementations

impl ChannelRegistry

pub fn new() -> Self

pub fn register( &mut self, adapter: Arc<dyn ChannelAdapter>, ) -> Result<(), ChannelError>

pub fn ids(&self) -> Vec<ChannelId>

pub fn get(&self, id: &ChannelId) -> Option<Arc<dyn ChannelAdapter>>

pub fn listen(&self, id: &ChannelId) -> Result<ChannelStream, ChannelError>

pub fn send( &self, message: OutboundMessage, ) -> ChannelFuture<'_, DeliveryReceipt>

pub fn health(&self, id: &ChannelId) -> ChannelFuture<'_, ChannelHealth>

pub fn dispatch<F, Fut>( &self, inbound: InboundMessage, handler: F, ) -> ChannelFuture<'_, DeliveryReceipt>

where F: FnOnce(InboundMessage) -> Fut + Send + 'static, Fut: Future<Output = Result<OutboundMessage, ChannelError>> + Send + 'static,

Trait Implementations

impl Clone for ChannelRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelRegistry

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

Formats the value using the given formatter.

impl Default for ChannelRegistry

fn default() -> Self

Returns the “default value” for a type.