Struct UdCore 

pub struct UdCore { /* private fields */ }

The sans-io core of the user data connector.

Implementations

impl UdCore

pub fn new(category: impl Into<String>) -> Self

An empty core for the category of the account.

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

Woken whenever a subscription changes state.

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

The state of a subscription.

pub fn register( &mut self, id: SubscriptionId, kind: UdSubKind, topics: &[String], reqs: &[(String, String)], )

Registers a subscription for topics; reqs are (request id, topic) pairs of the requests that are about to be sent.

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 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, link_id: &str) -> ClientOrderId

The cid of an order of the exchange: the one in its orderLinkId, 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.