cometd-client 0.3.0-alpha.4

Client for LongPolling CometD connections
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

mod command;
mod error;
mod event;
mod message;

/// Contains different implementations for `AccessToken` trait.
pub mod access_token;

use tokio::sync::mpsc;

pub(crate) use command::*;
pub use {access_token::AccessToken, error::*, event::*, message::*};

pub(crate) type InactiveEventReceiver<Msg> =
    async_broadcast::InactiveReceiver<CometdClientEvent<Msg>>;
#[allow(missing_docs)]
pub type EventReceiver<Msg> = async_broadcast::Receiver<CometdClientEvent<Msg>>;
pub(crate) type EventSender<Msg> = async_broadcast::Sender<CometdClientEvent<Msg>>;

pub(crate) type CmdReceiver = mpsc::Receiver<Command>;
pub(crate) type CmdSender = mpsc::Sender<Command>;