Struct Bus

pub struct Bus { /* private fields */ }

Implementations

impl Bus

pub fn new() -> Self

pub async fn register<M: Message, B: Builder<M>>(&self, builder: B) -> &Self

where B::Context: Handler<M>,

pub async fn register_mapper<M: Message, R: Message, E: ErrorMessage, C: Send + Clone + Sync + FnMut(u32, u32, M) -> Result<R, E> + 'static>( &self, cb: C, ) -> &Self

pub async fn send<M: Message>(&self, inner: M) -> Result<(), Error>

pub async fn send_with_stream<M: Message>( &self, stream_id: u32, inner: M, ) -> Result<(), Error>

pub async fn shutdown(&self)

Terminating everything ASAP

pub async fn close(&self)

Closing providers and waiting when handler queues were drained

pub fn wait(&self) -> impl Future<Output = ()> + '_

Waiting the processing been done

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Bus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Bus

fn default() -> Bus

Returns the “default value” for a type.