Struct cometd_client::CometdClient

pub struct CometdClient { /* private fields */ }

A cometd Client.

Implementations

impl CometdClient

pub async fn connect<Msg>(&self) -> CometdResult<Vec<Data<Msg>>>where
    Msg: DeserializeOwned,

Send connect request.

Example

    let data = client.connect::<serde_json::Value>().await?;

impl CometdClient

pub async fn disconnect(&self) -> CometdResult<()>

Send disconnect request.

Example

    client.disconnect().await?;

impl CometdClient

pub async fn handshake(&self) -> CometdResult<()>

Send handshake request.

Example

    client.handshake().await?;

impl CometdClient

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

Send handshake request.

Example

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

impl CometdClient

pub fn update_access_token<AT>(&self, access_token: AT)where
    AT: AccessToken + 'static,

Method for update access token.

Example

    let access_token = Basic::create("username", Some("password")).unwrap();
    client.update_access_token(access_token);

pub async fn add_cookies<N, V>(
    &self,
    cookies: impl IntoIterator<Item = (N, V)> + Send
)where
    N: Into<Cow<'static, str>>,
    V: Into<Cow<'static, str>>,

Method for adding cookies.

Example

    client.add_cookies([("a", "1")]);

Trait Implementations

impl Debug for CometdClient

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

Formats the value using the given formatter.