Struct FeedHandler 

pub struct FeedHandler { /* private fields */ }

Processes incoming WebSocket messages and converts them to Nautilus domain objects.

The handler owns the WebSocketClient exclusively within the lock-free I/O boundary, eliminating RwLock contention on the hot path.

Implementations

impl FeedHandler

pub fn new( account_id: Option<AccountId>, cmd_rx: UnboundedReceiver<HandlerCommand>, out_tx: UnboundedSender<NautilusWsMessage>, raw_rx: UnboundedReceiver<Message>, client: WebSocketClient, signal: Arc<AtomicBool>, subscriptions: SubscriptionState, bars_timestamp_on_close: bool, ) -> Self

Creates a new FeedHandler.

pub async fn run(&mut self)

Main processing loop for the handler.

Panics

This method will not panic. The expect call on iter.next() is safe because we explicitly check that nautilus_msgs is not empty before calling it.

pub fn register_bar_type(&mut self, topic: String, bar_type: BarType)

Registers a bar type for a specific topic (e.g., “BTC-USD/1MIN”).

pub fn unregister_bar_type(&mut self, topic: &str)

Unregisters a bar type for a specific topic.

pub async fn handle_message( &mut self, msg: DydxWsMessage, ) -> DydxWsResult<Vec<NautilusWsMessage>>

Handles control messages from the fallback parsing path.

Channel data is handled directly via handle_feed_message().

Errors

Returns an error if the message cannot be processed.

Trait Implementations

impl Debug for FeedHandler

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

Formats the value using the given formatter.