Struct EventbusBridge 

pub struct EventbusBridge { /* private fields */ }

Available on crate feature bridge only.

A bridge to connect two seperated Eventbus

Implementations

impl EventbusBridge

pub fn new(bus: Eventbus) -> Self

create a new bridge from an exist Eventbus

pub async fn connect<E: AsRef<str>>(&self, endpoint: E) -> Result<(), Error>

connect to another Eventbus

pub async fn listen(self, addr: SocketAddr) -> Result<(), Error>

bind to an address and listen for connections

pub async fn create_topic<T: 'static, K: Into<TopicKey>>( &self, topic_key: K, ) -> BridgedTopic<T>

create a Topic using a topic key

pub async fn register<T: DeserializeOwned + Send + Sync + 'static, K: Into<TopicKey>, L: Listener<T>>( &self, topic_key: K, listener: L, ) -> BridgedEventListener<T>

register a listener to bridged eventbus

pub async fn unregister<T: 'static>( &self, event_listener: BridgedEventListener<T>, )

unregister a bridged event listener

pub async fn post<T: Serialize + Send + Sync + 'static>(&self, event: &Event<T>)

post an event to eventbus

Trait Implementations

impl Clone for EventbusBridge

fn clone(&self) -> EventbusBridge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventbusBridge

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.