Struct BinanceFuturesExecWsFeedHandler 

pub struct BinanceFuturesExecWsFeedHandler { /* private fields */ }

Binance Futures execution WebSocket handler.

Processes user data stream messages and maintains pending order state to correlate WebSocket updates with the original order context.

Implementations

impl BinanceFuturesExecWsFeedHandler

pub fn new( clock: &'static AtomicTime, trader_id: TraderId, account_id: AccountId, account_type: AccountType, product_type: BinanceProductType, signal: Arc<AtomicBool>, triggered_algo_order_ids: Arc<RwLock<AHashSet<ClientOrderId>>>, cmd_rx: UnboundedReceiver<ExecHandlerCommand>, msg_rx: UnboundedReceiver<NautilusWsMessage>, ) -> Self

Creates a new BinanceFuturesExecWsFeedHandler instance.

pub async fn next(&mut self) -> Option<NautilusExecWsMessage>

Processes commands and messages, returning the next output event.

pub fn is_triggered_algo_order(&self, client_order_id: &ClientOrderId) -> bool

Returns whether a client order ID is a triggered algo order.

This is used to determine which cancel endpoint to use:

• Non-triggered algo orders use DELETE /fapi/v1/algoOrder
• Triggered algo orders use regular DELETE /fapi/v1/order

Panics

Panics if triggered_algo_order_ids lock is poisoned.

Trait Implementations

impl Debug for BinanceFuturesExecWsFeedHandler

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

Formats the value using the given formatter.