Struct RealtimeSession 

pub struct RealtimeSession { /* private fields */ }

Real-time hubs, client, session, events, messages, and invocation decoding. Real-time hubs, client, session, events, messages, and invocation decoding. Real-time hubs, client, session, events, messages, and invocation decoding. Subscription and invocation admission bound to one exact ready socket. This handle cannot stop or reconnect the transport and does not keep its owner alive.

Implementations

impl RealtimeSession

pub const fn generation(&self) -> RealtimeGeneration

The socket to which every invocation through this handle is bound.

pub async fn invoke( &self, target: impl Into<String>, arguments: Vec<Value>, ) -> Result<(), RealtimeError>

Invokes an arbitrary provider target and waits for its completion frame.

Errors

Returns an error when disconnected, a bounded capacity is exhausted, the provider rejects the invocation, or completion times out. A timeout or cancellation after queue admission has an unknown outcome and reclaims only that invocation slot. It never closes the connection or retries the call.

pub async fn subscribe_contract_trades( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Subscribes to market trades for a contract.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_contract_trades( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Unsubscribes from market trades for a contract.

Errors

Returns a real-time invocation error.

pub async fn subscribe_contract_quotes( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Subscribes to market quotes for a contract.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_contract_quotes( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Unsubscribes from market quotes for a contract.

Errors

Returns a real-time invocation error.

pub async fn subscribe_contract_depth( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Subscribes to market depth for a contract.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_contract_depth( &self, contract: &ContractId, ) -> Result<(), RealtimeError>

Unsubscribes from market depth for a contract.

Errors

Returns a real-time invocation error.

pub async fn subscribe_accounts(&self) -> Result<(), RealtimeError>

Subscribes to account updates.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_accounts(&self) -> Result<(), RealtimeError>

Unsubscribes from account updates.

Errors

Returns a real-time invocation error.

pub async fn subscribe_orders( &self, account: AccountId, ) -> Result<(), RealtimeError>

Subscribes to order updates for an account.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_orders( &self, account: AccountId, ) -> Result<(), RealtimeError>

Unsubscribes from order updates for an account.

Errors

Returns a real-time invocation error.

pub async fn subscribe_positions( &self, account: AccountId, ) -> Result<(), RealtimeError>

Subscribes to position updates for an account.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_positions( &self, account: AccountId, ) -> Result<(), RealtimeError>

Unsubscribes from position updates for an account.

Errors

Returns a real-time invocation error.

pub async fn subscribe_trades( &self, account: AccountId, ) -> Result<(), RealtimeError>

Subscribes to trade updates for an account.

Errors

Returns a real-time invocation error.

pub async fn unsubscribe_trades( &self, account: AccountId, ) -> Result<(), RealtimeError>

Unsubscribes from trade updates for an account.

Errors

Returns a real-time invocation error.

Trait Implementations

impl Clone for RealtimeSession

fn clone(&self) -> Self

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.