Struct MdCore 

pub struct MdCore { /* private fields */ }

The sans-io core of the market data connector.

Implementations

impl MdCore

pub fn new() -> MdCore

An empty core.

pub fn notifier(&self) -> Arc<Notify>

Woken whenever a subscription changes state.

pub fn desired(&self) -> &SubscriptionSet

The subscriptions the core serves.

pub fn register( &mut self, id: SubscriptionId, kind: SubscriptionKind, topic: &str, req_id: Option<&str>, )

Registers a subscription: frames of topic belong to id and are read as kind. req_id ties the answer of the exchange to the topic.

pub fn add_request(&mut self, req_id: &str, topic: &str)

Remembers a request id for a topic (after a book was asked for again).

pub fn forget(&mut self, id: SubscriptionId) -> Vec<String>

Forgets a subscription. Returns the topics nobody listens to any more.

pub fn has_topic(&self, topic: &str) -> bool

Whether any subscription listens to the topic.

pub fn book_waits(&self, id: SubscriptionId) -> bool

Whether the subscription is an order book that waits for a snapshot.

pub fn sub_state(&self, id: SubscriptionId) -> (SubState, Option<String>)

The state of a subscription.

pub fn take_gaps(&mut self) -> Vec<String>

The topics whose order book lost a delta since the last call. The connector asks the exchange for a new snapshot of each.

Trait Implementations

impl BrokerCore for MdCore

type Frame = WsIncoming

The inbound frame type: for example String for WebSocket text, or a decoded message.

fn on_frame( &mut self, frame: <MdCore as BrokerCore>::Frame, now: Instant, out: &mut EventSink, )

Handles one inbound transport frame received at now.

fn poll_transmit(&mut self) -> Option<Outbound>

Takes the next outbound wire message, if any. Call it until it returns None.

fn poll_timeout(&self) -> Option<Instant>

When the core wants on_timeout to be called next, or None if it has no timer pending.

fn on_timeout(&mut self, _now: Instant, _out: &mut EventSink)

Handles a timer that fired. now is the time the timer was due.

fn apply(&mut self, desired: &SubscriptionSet)

Tells the core the full set of subscriptions the consumer wants now.

impl Debug for MdCore

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

Formats the value using the given formatter.

impl Default for MdCore

fn default() -> MdCore

Returns the “default value” for a type.