Struct UdCore 

pub struct UdCore { /* private fields */ }

The sans-io core of the user data connector.

Implementations

impl UdCore

pub fn new(exchange: impl Into<String>, boards: BoardBook) -> Self

An empty core for the exchange of the portfolio, with the book of boards it reads positions from.

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

Woken whenever a subscription changes state. The connector waits on it for the confirmation of a new subscription.

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.

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

Registers a subscription: frames with this guid belong to id and are read as kind.

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

Forgets a subscription.

pub fn learn_order_id(&mut self, order_id: &str, cid: ClientOrderId)

Remembers that the order with this number is the order of cid.

pub fn cid_of_order_id(&self, order_id: &str) -> Option<ClientOrderId>

The cid of the order with this number, if the core has seen it.

pub fn resolve_cid( &mut self, order_id: &str, comment: Option<&str>, ) -> ClientOrderId

The cid of an order of the broker: the one in its comment, else the one learned for its number, else a stable made-up one (the order is not ours).

Trait Implementations

impl BrokerCore for UdCore

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 UdCore

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

Formats the value using the given formatter.