Struct LongPollingServiceContext 

pub struct LongPollingServiceContext<AdditionalData, CustomData> { /* private fields */ }

Context for sending messages to channels.

Implementations

impl<AdditionalData, CustomData> LongPollingServiceContext<AdditionalData, CustomData>

pub fn rx(&self) -> CometdEventReceiver<AdditionalData, CustomData>

Get new events receiver.

Example

    let mut rx = context.rx();
     
    while let Some(event) = rx.recv().await {
        println!("Got event: `{event:?}`");
    }

pub fn tx(&self) -> CometdCustomDataSender<AdditionalData, CustomData>

Get new events sender.

Example

 async {
    let tx = context.tx();
     
    tx.send("hello").await;

pub async fn send( &self, channel: &str, message: impl Debug + Serialize, ) -> Result<(), SendError>

Send message to channel.

Example

#[derive(Debug, Clone, serde::Serialize)]
    struct Data<'a> {
        msg: std::borrow::Cow<'a, str>,
        r#bool: bool,
        num: u64,
    }

    let context = axum_cometd::LongPollingServiceContextBuilder::new()
        .timeout(Duration::from_secs(1))
        .max_interval(Duration::from_secs(2))
        .client_channel_capacity(10_000)
        .subscription_channel_capacity(20_000)
        .build::<(), ()>();

    loop {
        context
            .send(
                "/topic",
                Data {
                    msg: "Hello World!!!".into(),
                    r#bool: true,
                    num: u64::MAX,
                },
            )
            .await?;
        tokio::time::sleep(std::time::Duration::from_millis(1000)).await;
    }

pub async fn send_to_client( &self, channel: &str, client_id: &ClientId, msg: impl Debug + Serialize, ) -> Result<(), SendError>

Send message direct to client.

pub async fn unsubscribe(self: &Arc<Self>, client_id: ClientId)

Remove client.

Trait Implementations

impl<AdditionalData: Debug, CustomData: Debug> Debug for LongPollingServiceContext<AdditionalData, CustomData>

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

Formats the value using the given formatter.