Struct comet_eventbus::bridge::EventbusBridge

pub struct EventbusBridge { /* private fields */ }

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> ) -> Result<(), Vec<BridgerClient>>

post an event to eventbus, returning a Result

Panics

This method panics if T cannot be successfully serialized.

Errors

This method failed if any of send task to the connected eventbus failed. A Vec of BridgerClient is returned for retrying.

Trait Implementations

impl Clone for EventbusBridge

fn clone(&self) -> EventbusBridge

Returns a copy 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.