Struct MarketFeed 

pub struct MarketFeed { /* private fields */ }

A filtered stream of decoded MarketEvents for a single perp.

Created via MarketFeed::subscribe(). Call next() in a loop to receive events. Returns None when the WebSocket connection is lost.

Implementations

impl MarketFeed

pub async fn subscribe( ws: &WsManager, perp_manager: Address, beacon: Address, perp_id: B256, ) -> Result<Self>

Subscribe to events for a single perp.

Creates a WebSocket log subscription filtered to the perp_manager and beacon contract addresses. PerpManager events are further filtered by perp_id in next(). Beacon IndexUpdated events are already scoped to this perp by the beacon address filter.

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

Receive the next decoded event for this perp.

Blocks until a matching event arrives. Returns None when the WebSocket connection is lost (sender dropped).

Skips unrecognized events and events belonging to other perps.

pub fn perp_id(&self) -> B256

The perp ID this feed is filtering for.

Trait Implementations

impl Debug for MarketFeed

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

Formats the value using the given formatter.