Struct L2Client 

pub struct L2Client { /* private fields */ }

L2 book client for a single symbol. No retries/reconnection logic; it just subscribes to and maintains the book.

To use this, call L2Client::connect to construct a client, drive its next method to apply updates, and use the accessors on L2Client to access the current state of the book.

If you need multiple readers/consumers of this client, use L2Client::handle() to create a cheaply cloneable handle to pass around.

Implementations

impl L2Client

pub async fn new( channel: Channel, symbol: String, venue: Option<MarketdataVenue>, ) -> Result<Self>

pub async fn connect<D>( endpoint: D, symbol: String, venue: Option<MarketdataVenue>, ) -> Result<Self>

where D: TryInto<Endpoint>, D::Error: Into<Box<dyn Error + Send + Sync>>,

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

pub fn handle(&self) -> L2ClientHandle

pub fn sequence(&self) -> SequenceIdAndNumber

pub fn book(&self) -> MappedMutexGuard<'_, LevelBook>