Struct WsInner 

struct WsInner {
    sink: Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>,
    subscriptions: Vec<Value>,
    depth_senders: Vec<UnboundedSender<Result<DepthUpdate, O2Error>>>,
    orders_senders: Vec<UnboundedSender<Result<OrderUpdate, O2Error>>>,
    trades_senders: Vec<UnboundedSender<Result<TradeUpdate, O2Error>>>,
    balances_senders: Vec<UnboundedSender<Result<BalanceUpdate, O2Error>>>,
    nonce_senders: Vec<UnboundedSender<Result<NonceUpdate, O2Error>>>,
}

Shared inner state for the WebSocket connection.

Fields

sink: Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>

subscriptions: Vec<Value>

depth_senders: Vec<UnboundedSender<Result<DepthUpdate, O2Error>>>

orders_senders: Vec<UnboundedSender<Result<OrderUpdate, O2Error>>>

trades_senders: Vec<UnboundedSender<Result<TradeUpdate, O2Error>>>

balances_senders: Vec<UnboundedSender<Result<BalanceUpdate, O2Error>>>

nonce_senders: Vec<UnboundedSender<Result<NonceUpdate, O2Error>>>

Implementations

impl WsInner

fn new() -> Self

fn prune_closed_senders(&mut self)

Remove closed senders from all sender lists.

fn close_all_senders(&mut self)

Close all sender channels (signals receivers to terminate).

fn close_all_senders_with_error(&mut self, msg: &str)

Send disconnect error to all subscribers, then clear.