Struct cometd_client::CometdClientBuilder

pub struct CometdClientBuilder<'b, 'c, 'd, 'e> { /* private fields */ }

A builder to construct CometdClient.

Implementations

impl<'b, 'c, 'd, 'e> CometdClientBuilder<'b, 'c, 'd, 'e>

pub fn new(endpoint: Url) -> Self

Construct a new ClientBuilder.

pub fn build(self) -> CometdResult<CometdClient>

Return a CometdClient.

Example

use cometd_client::CometdClientBuilder;

let client = CometdClientBuilder::new("http://[::1]:1025/notifications/".parse()?)
    .build()?;

pub fn handshake_base_path(self, url: &'b str) -> Self

Set cometd server handshake url path.

Example

use cometd_client::CometdClientBuilder;

let app = CometdClientBuilder::new("http://[::1]:1025/notifications/".parse()?)
    .handshake_base_path("hand/") // http://[::1]:1025/notifications/hand/handshake
    .build()?;

pub fn subscribe_base_path(self, url: &'c str) -> Self

Set cometd server subscribe url path.

Example

use cometd_client::CometdClientBuilder;

let app = CometdClientBuilder::new("http://[::1]:1025/notifications/".parse()?)
    .subscribe_base_path("sub/") // http://[::1]:1025/notifications/sub/
    .build()?;

pub fn connect_base_path(self, url: &'d str) -> Self

Set cometd server connect url path.

Example

use cometd_client::CometdClientBuilder;

let app = CometdClientBuilder::new("http://[::1]:1025/notifications/".parse()?)
    .connect_base_path("con/") // http://[::1]:1025/notifications/con/connect
    .build()?;

pub fn disconnect_base_path(self, url: &'e str) -> Self

Set cometd server disconnect url path.

Example

use cometd_client::CometdClientBuilder;

let app = CometdClientBuilder::new("http://[::1]:1025/notifications/".parse()?)
    .connect_base_path("discon/") // http://[::1]:1025/notifications/discon/disconnect
    .build()?;

pub fn timeout_ms(self, timeout_ms: u64) -> Self

Set timeout option in handshake request.

pub fn interval_ms(self, interval_ms: u64) -> Self

Set interval option in handshake request.

pub fn access_token<AT>(self, access_token: AT) -> Selfwhere
    AT: AccessToken + 'static,

Set interval option in handshake request.

Trait Implementations

impl<'b, 'c, 'd, 'e> Debug for CometdClientBuilder<'b, 'c, 'd, 'e>

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

Formats the value using the given formatter.