Struct messagebus::Bus

pub struct Bus { /* fields omitted */ }

Implementations

impl Bus

pub fn build() -> BusBuilder

pub fn is_closing(&self) -> bool

pub async fn ready(&self)

pub async fn close(&self)

pub async fn flush(&self)

pub async fn flush_and_sync(&self)

pub fn try_send<M: Message + Clone>(&self, msg: M) -> Result<(), Error<M>>

pub fn try_send_ext<M: Message + Clone>(
    &self,
    msg: M,
    _options: SendOptions
) -> Result<(), Error<M>>

pub fn send_blocking<M: Message + Clone>(&self, msg: M) -> Result<(), Error<M>>

pub fn send_blocking_ext<M: Message + Clone>(
    &self,
    msg: M,
    options: SendOptions
) -> Result<(), Error<M>>

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

pub async fn send_ext<M: Message + Clone>(
    &self,
    msg: M,
    _options: SendOptions
) -> Result<(), Error<M>>

pub fn force_send<M: Message + Clone>(&self, msg: M) -> Result<(), Error<M>>

pub fn force_send_ext<M: Message + Clone>(
    &self,
    msg: M,
    _options: SendOptions
) -> Result<(), Error<M>>

pub fn try_send_one<M: Message>(&self, msg: M) -> Result<(), Error<M>>

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

pub fn send_one_blocking<M: Message>(&self, msg: M) -> Result<(), Error<M>>

pub async fn request<M: Message, R: Message>(
    &self,
    req: M,
    options: SendOptions
) -> Result<R, Error<M>>

pub async fn request_we<M, R, E>(
    &self,
    req: M,
    options: SendOptions
) -> Result<R, Error<M, E>> where
    M: Message,
    R: Message,
    E: StdSyncSendError, 

pub async fn send_boxed(
    &self,
    msg: Box<dyn Message>,
    _options: SendOptions
) -> Result<(), Error<Box<dyn Message>>>

pub async fn send_boxed_one(
    &self,
    msg: Box<dyn Message>,
    _options: SendOptions
) -> Result<(), Error<Box<dyn Message>>>

pub async fn request_boxed(
    &self,
    req: Box<dyn Message>,
    options: SendOptions
) -> Result<Box<dyn Message>, Error<Box<dyn Message>>>

pub async fn request_boxed_we<E: StdSyncSendError>(
    &self,
    req: Box<dyn Message>,
    options: SendOptions
) -> Result<Box<dyn Message>, Error<Box<dyn Message>, E>>

pub async fn send_deserialize_one<'a, 'b: 'a, 'c: 'a>(
    &'a self,
    tt: TypeTag,
    de: &'b mut dyn Deserializer<'c>,
    _options: SendOptions
) -> Result<(), Error<Box<dyn Message>>>

pub async fn request_deserialize<'a, 'b: 'a, 'c: 'a>(
    &'a self,
    tt: TypeTag,
    de: &'b mut dyn Deserializer<'c>,
    options: SendOptions
) -> Result<Box<dyn Message>, Error<Box<dyn Message>>>

pub fn deserialize_message(
    &self,
    tt: TypeTag,
    de: &mut dyn Deserializer<'_>
) -> Result<Box<dyn Message>, Error<Box<dyn Message>>>

pub fn stats(&self) -> impl Iterator<Item = Stats> + '_

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Bus

Returns a copy of the value.

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

Performs copy-assignment from source.