Struct MdCore 

pub struct MdCore { /* private fields */ }

The sans-io core of the market data connector.

Implementations

impl MdCore

pub fn new() -> Self

An empty core.

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

Woken whenever a subscription changes state (confirmed, refused, or data came). The connector waits on it for the confirmation of a new subscription.

pub fn desired(&self) -> &SubscriptionSet

The subscriptions the core was told about, as a set.

pub fn register( &mut self, guid: &str, id: SubscriptionId, kind: SubscriptionKind, )

Registers a subscription: frames with this guid belong to id and are read as kind. The connector calls it before the request is sent, so the confirmation cannot overtake it.

pub fn forget(&mut self, guid: &str)

Forgets a subscription (the data that still arrives for its guid is dropped).

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

The state of a subscription.

pub fn failure(&self, id: SubscriptionId) -> Option<&str>

The reason the broker gave when it refused a subscription.

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: Self::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

Formats the value using the given formatter.

impl Default for MdCore

fn default() -> MdCore

Returns the “default value” for a type.