BusEventReader

Trait BusEventReader 

Source
pub trait BusEventReader<T: BusEvent> {
    // Required method
    fn read<C: EventBusConfig>(&mut self, config: &C) -> Vec<EventWrapper<T>>;
}
Expand description

Common capabilities shared by all bus event readers.

Required Methods§

Source

fn read<C: EventBusConfig>(&mut self, config: &C) -> Vec<EventWrapper<T>>

Drain the buffered events for the supplied configuration.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<'w, 's, T: BusEvent + Event> BusEventReader<T> for KafkaEventReader<'w, 's, T>

Source§

impl<'w, 's, T: BusEvent + Event> BusEventReader<T> for RedisEventReader<'w, 's, T>