Struct RealtimeSession 

pub struct RealtimeSession { /* private fields */ }

Cloneable realtime session that multiplexes concurrent RPCs and pushed events over one WebSocket connection.

Create an event receiver with RealtimeSession::subscribe before issuing RPCs that may cause the server to push update hints.

Implementations

impl RealtimeSession

pub async fn connect(url: &str, token: &str) -> Result<Self, RealtimeError>

Connects a multiplexed realtime session using the default SDK identity.

pub async fn connect_with_identity( url: &str, token: &str, identity: ClientIdentity, ) -> Result<Self, RealtimeError>

Connects a multiplexed realtime session with an explicit client identity.

pub fn subscribe(&self) -> RealtimeEventReceiver

Subscribes to server-pushed events routed by this session.

pub fn is_closed(&self) -> bool

Returns whether the session transport task has stopped.

pub async fn call<R>(&self, request: R) -> Result<R::Response, RealtimeError>

where R: RpcRequest,

Invokes a typed Inline RPC while the same transport continues routing pushed events to subscribers.

pub async fn invoke( &self, method: Method, input: Input, ) -> Result<Result, RealtimeError>

Invokes an Inline RPC while the same transport continues routing pushed events and other concurrent RPC results.

Trait Implementations

impl Clone for RealtimeSession

fn clone(&self) -> RealtimeSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RealtimeSession

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

Formats the value using the given formatter.