Struct DirectChannel 

pub struct DirectChannel { /* private fields */ }

Direct, synchronous handoff channel.

No internal buffering: send immediately dispatches the exchange to all subscribers in registration order. Each subscriber receives a cloned Exchange.

Implementations

impl DirectChannel

pub fn with_random_id() -> DirectChannel

Create a new direct channel with an auto-generated UUID-based id (direct:<uuid>).

pub fn with_id<S>(id: S) -> DirectChannel

where S: Into<String>,

Create a new direct channel with an explicit id.

pub fn with_subscribers<I, F>(id: Option<&str>, subs: I) -> DirectChannel

where I: IntoIterator<Item = F>, F: Fn(Exchange) -> Result<(), Error> + Send + Sync + 'static,

Convenience: construct with optional id and an initial iterator of subscribers. Each provided closure is subscribed in iteration order.

pub fn id(&self) -> &str

Returns the channel identifier.

pub fn subscribe<F>(&self, f: F) -> usize

where F: Fn(Exchange) -> Result<(), Error> + Send + Sync + 'static,

Register a subscriber. Returns total subscriber count after insertion.

Trait Implementations

impl Channel for DirectChannel

fn id(&self) -> &str

fn send<'life0, 'async_trait>( &'life0 self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, DirectChannel: 'async_trait,

fn kind(&self) -> &'static str

fn as_any(&self) -> &(dyn Any + 'static)

impl Debug for DirectChannel

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

Formats the value using the given formatter.

impl SubscribableChannel for DirectChannel

fn subscribe<F>(&self, f: F) -> usize

where F: Fn(Exchange) -> Result<(), Error> + Send + Sync + 'static,