Trait event_store_core::event_bus::EventBus

source · 
pub trait EventBus: Debug + Default + Send + Unpin + 'static {
    // Required methods
    fn bus_name() -> &'static str;
    fn create_stream(&mut self) -> BoxedStream;
}

Required Methods§

source

fn bus_name() -> &'static str

source

fn create_stream(&mut self) -> BoxedStream

Implementors§