Struct RealtimeClient 

pub struct RealtimeClient { /* private fields */ }

Stateful realtime connection for issuing Inline RPC calls.

Implementations

impl RealtimeClient

pub fn builder( url: impl Into<String>, token: impl Into<String>, ) -> RealtimeClientBuilder

Starts a realtime client builder.

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

Connects to realtime using the default SDK identity.

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

Connects to realtime using a caller-provided client identity.

impl RealtimeClient

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

where R: RpcRequest,

Invokes a typed Inline RPC request.

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

Invokes an Inline RPC method and waits for the matching result.

pub fn rpc_timeout(&self) -> Option<Duration>

Returns the configured per-RPC timeout.