Struct WsDispatchState 

pub struct WsDispatchState {
    pub order_identities: DashMap<ClientOrderId, OrderIdentity>,
    /* private fields */
}

Shared state for cross-stream event deduplication between the private and business WebSocket dispatch loops.

Fields

order_identities: DashMap<ClientOrderId, OrderIdentity>

Implementations

impl WsDispatchState

pub fn contains_accepted(&self, cid: &ClientOrderId) -> bool

Returns whether acceptance was already emitted for the order.

pub fn insert_accepted(&self, cid: ClientOrderId, venue_order_id: VenueOrderId)

Records that acceptance was emitted for the order.

pub fn contains_triggered(&self, cid: &ClientOrderId) -> bool

Returns whether the order was already triggered.

pub fn insert_triggered(&self, cid: ClientOrderId)

Records that the order was triggered.

pub fn contains_filled(&self, cid: &ClientOrderId) -> bool

Returns whether the order was already filled.

pub fn insert_filled(&self, cid: ClientOrderId)

Records that the order was filled.

pub fn contains_terminal(&self, cid: &ClientOrderId) -> bool

Returns whether the order already reached a terminal state.

pub fn insert_terminal(&self, cid: ClientOrderId)

Records that the order reached a terminal state.

pub fn check_and_insert_trade(&self, trade_id: TradeId) -> bool

Returns true if this trade was already emitted (duplicate). Uses atomic insert to avoid TOCTOU races between concurrent streams.

pub fn contains_trade(&self, trade_id: &TradeId) -> bool

Trait Implementations

impl Debug for WsDispatchState

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

Formats the value using the given formatter.

impl Default for WsDispatchState

fn default() -> Self

Returns the “default value” for a type.