axum-cometd 0.9.3

Framework for CometD server creation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::Event;
use async_broadcast::{Receiver, RecvError};
use std::sync::Arc;

/// Event channel receiver.
#[derive(Debug)]
pub struct CometdEventReceiver<AdditionalData, CustomData>(
    pub(crate) Receiver<Arc<Event<AdditionalData, CustomData>>>,
);

impl<AdditionalData, CustomData> CometdEventReceiver<AdditionalData, CustomData> {
    /// Receive event from event channel.
    /// Return `None` if channel was closed.
    #[inline(always)]
    pub async fn recv(&mut self) -> Option<Arc<Event<AdditionalData, CustomData>>> {
        match self.0.recv().await {
            Ok(event) => Some(event),
            Err(RecvError::Closed) => None,
            Err(RecvError::Overflowed(_)) => unreachable!(),
        }
    }
}