Struct Client 

pub struct Client { /* private fields */ }

Realtime websocket client.

Implementations

impl Client

pub fn new( ws_url: impl Into<String>, api_url: impl Into<String>, credentials: Option<Credentials>, max_queue: Option<usize>, ) -> Self

pub fn with_timeout( ws_url: impl Into<String>, api_url: impl Into<String>, credentials: Option<Credentials>, max_queue: Option<usize>, timeout: Duration, ) -> Self

pub async fn subscribe_raw( &self, channel: &str, ) -> Result<TypedSubscription<Vec<u8>>>

Subscribe to a protobuf channel and receive raw publication payloads.

Returns only after the initial websocket handshake and channel subscription succeed.

pub async fn subscribe_proto<T, F>( &self, channel: &str, decode: F, ) -> Result<TypedSubscription<T>>

where T: Send + 'static, F: Fn(&[u8]) -> Result<T> + Send + Sync + 'static,

Subscribe to a protobuf Centrifugo channel and decode publications.

Returns only after the initial websocket handshake and channel subscription succeed.

pub async fn subscribe_proto_with_options<T, F>( &self, channel: &str, decode: F, auto_reconnect: bool, ) -> Result<TypedSubscription<T>>

where T: Send + 'static, F: Fn(&[u8]) -> Result<T> + Send + Sync + 'static,

Subscribe with optional auto-reconnect control.

Snapshot-then-stream sets auto_reconnect=false so it can rebuild REST state between reconnect attempts.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.