Struct cometd_client::CometdClient

pub struct CometdClient<Msg> { /* private fields */ }

A cometd Client.

Implementations

impl<Msg> CometdClient<Msg>

pub fn rx(&self) -> CometdEventReceiver<Msg>

Return client event receiver channel.

Example

    let mut event_rx = client.rx();
     
    client.subscribe(&["/topic0"]).await;

    while let Some(event) = event_rx.recv().await {
        println!("Got cometd client event: `{event:?}`.");
    }

pub async fn subscribe(&self, subscriptions: &[impl Serialize + Send + Sync])

Ask client command loop to send subscribe request.

Example

    client.subscribe(&["/topic0", "/topic1"]).await;

Trait Implementations

impl<Msg: Debug> Debug for CometdClient<Msg>

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

Formats the value using the given formatter.