Skip to main content

RealtimeSession

projectx_client

Struct RealtimeSession

pub struct RealtimeSession { /* private fields */ }

Expand description

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) -> RealtimeSession

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more

impl Debug for RealtimeSession

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl !RefUnwindSafe for RealtimeSession

impl !UnwindSafe for RealtimeSession

impl Freeze for RealtimeSession

impl Send for RealtimeSession

impl Sync for RealtimeSession

impl Unpin for RealtimeSession

impl UnsafeUnpin for RealtimeSession

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

impl<T> Same for T

type Output = T

Should always be Self

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more