Struct AsyncBroker 

pub struct AsyncBroker { /* private fields */ }

Publish-subscribe broker handle.

Example usage

use celp_sdk::async_broker::{AsyncBroker, IntoPublisher, IntoSubscriber, Subscribe};
use futures::StreamExt;
let broker = AsyncBroker::new().unwrap();
let publisher = broker.clone().into_publisher().await.unwrap();
tokio::spawn(async {
    let mut subscriber = broker.into_subscriber().await.unwrap();
    subscriber
        .subscribe("example.channel")
        .await
        .unwrap();
    // The `.boxed()` call can usually be omitted; it is included here due to
    // https://github.com/rust-lang/rust/issues/100013
    let mut stream = subscriber.into_message_stream().await.boxed();
    while let Some(msg) = stream.next().await {
        // handle `msg`
    }
});
// You can use `publisher.publish()` etc. to publish your own messages

Implementations

impl AsyncBroker

pub fn new() -> Result<Self, SubscribeError>

Create a new instance of broker with default config

Trait Implementations

impl Clone for AsyncBroker

fn clone(&self) -> AsyncBroker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl IntoPublisher for AsyncBroker

fn into_publisher<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<impl Publish, PublishError>> + Send + 'async_trait>>

where Self: 'async_trait,

impl IntoSubscriber for AsyncBroker

fn into_subscriber<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<impl Subscribe, SubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait,