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>, ) -> Self

Creates a new FeedHandler.

pub async fn run(&mut self)

Main processing loop for the handler.

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 fn handle_message( &self, msg: DydxWsMessage, ) -> DydxWsResult<Option<NautilusWsMessage>>

Processes a WebSocket message and converts it to Nautilus domain objects.

Errors

Returns an error if message parsing fails.

Trait Implementations

impl Debug for FeedHandler

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

Formats the value using the given formatter.