Struct AxOrdersWebSocketClient 

pub struct AxOrdersWebSocketClient { /* private fields */ }

Orders WebSocket client for Ax.

Provides authenticated order management including placing, canceling, and monitoring order status via WebSocket.

Implementations

impl AxOrdersWebSocketClient

pub fn new(url: String, account_id: AccountId, heartbeat: Option<u64>) -> Self

Creates a new Ax orders WebSocket client.

pub fn url(&self) -> &str

Returns the WebSocket URL.

pub fn account_id(&self) -> AccountId

Returns the account ID.

pub fn is_active(&self) -> bool

Returns whether the client is currently connected and active.

pub fn is_closed(&self) -> bool

Returns whether the client is closed.

pub fn cache_instrument(&self, instrument: InstrumentAny)

Caches an instrument for use during message parsing.

pub fn get_cached_instrument(&self, symbol: &Ustr) -> Option<InstrumentAny>

Returns a cached instrument by symbol.

pub async fn connect(&mut self, bearer_token: &str) -> AxOrdersWsResult<()>

Establishes the WebSocket connection with authentication.

Arguments

• bearer_token - The bearer token for authentication.

Errors

Returns an error if the connection cannot be established.

pub async fn place_order( &self, client_order_id: ClientOrderId, symbol: Ustr, side: AxOrderSide, quantity: i64, price: Decimal, time_in_force: AxTimeInForce, post_only: bool, tag: Option<String>, ) -> AxOrdersWsResult<i64>

Places an order via WebSocket.

Errors

Returns an error if the order command cannot be sent.

pub async fn cancel_order(&self, order_id: &str) -> AxOrdersWsResult<i64>

Cancels an order via WebSocket.

Errors

Returns an error if the cancel command cannot be sent.

pub async fn get_open_orders(&self) -> AxOrdersWsResult<i64>

Requests open orders via WebSocket.

Errors

Returns an error if the request command cannot be sent.

pub fn stream(&mut self) -> impl Stream<Item = AxOrdersWsMessage> + use<'_>

Returns a stream of messages from the WebSocket.

Panics

Panics if called more than once or before connecting.

pub async fn disconnect(&self)

Disconnects the WebSocket connection gracefully.

pub async fn close(&mut self)

Closes the WebSocket connection and cleans up resources.

Trait Implementations

impl Clone for AxOrdersWebSocketClient

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 AxOrdersWebSocketClient

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

Formats the value using the given formatter.