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.