Trait messagebus::BatchHandler

pub trait BatchHandler<M: Message>: Send + Sync {
    type Error: StdSyncSendError + Clone;
    type Response: Message;
    type InBatch: FromIterator<M> + Send;
    type OutBatch: IntoIterator<Item = Self::Response> + Send;
    fn handle(
        &self, 
        msg: Self::InBatch, 
        bus: &Bus
    ) -> Result<Self::OutBatch, Self::Error>;

    fn sync(&self, _bus: &Bus) -> Result<(), Self::Error> { ... }
}

Associated Types

type Error: StdSyncSendError + Clone

type Response: Message

type InBatch: FromIterator<M> + Send

type OutBatch: IntoIterator<Item = Self::Response> + Send

Required methods

fn handle(
    &self,
    msg: Self::InBatch,
    bus: &Bus
) -> Result<Self::OutBatch, Self::Error>

Provided methods

fn sync(&self, _bus: &Bus) -> Result<(), Self::Error>

Implementors