Skip to main content

dispatch_ws_message

Function dispatch_ws_message 

Source
pub fn dispatch_ws_message(
    message: OKXWsMessage,
    emitter: &ExecutionEventEmitter,
    state: &WsDispatchState,
    account_id: AccountId,
    instruments: &AHashMap<Ustr, InstrumentAny>,
    fee_cache: &mut AHashMap<Ustr, Money>,
    filled_qty_cache: &mut AHashMap<Ustr, Quantity>,
    order_state_cache: &mut AHashMap<ClientOrderId, OrderStateSnapshot>,
    clock: &AtomicTime,
)
Expand description

Dispatches a WebSocket message with cross-stream deduplication.

For orders with a tracked identity (submitted through this client), produces proper order events (OrderAccepted, OrderCanceled, OrderFilled, etc.). For untracked orders (external or pre-existing), falls back to execution reports for downstream reconciliation.