Struct binance_spot_connector_rust::tungstenite::WebSocketState

pub struct WebSocketState<T> { /* private fields */ }

Implementations

impl<T: Read + Write> WebSocketState<T>

pub fn new(socket: WebSocket<T>) -> Self

pub fn subscribe<'a>( &mut self, streams: impl IntoIterator<Item = &'a Stream> ) -> u64

Sends SUBSCRIBE message for the given streams.

streams are not validated. Invalid streams will be accepted by the server, but no data will be sent. Requests to subscribe an existing stream will be ignored by the server.

Returns the message id. This should be used to match the request with a future response. Sent messages should not share the same message id.

You should expect the server to respond with a similar message.

{ "method": "SUBSCRIBE", "params": [ <streams> ], "id": <id> }

pub fn unsubscribe<'a>( &mut self, streams: impl IntoIterator<Item = &'a Stream> ) -> u64

Sends UNSUBSCRIBE message for the given streams.

streams are not validated. Non-existing streams will be ignored by the server.

Returns the message id. This should be used to match the request with a future response. Sent messages should not share the same message id.

You should expect the server to respond with a similar message.

{ "method": "UNSUBSCRIBE", "params": [ <streams> ], "id": <id> }

pub fn subscriptions(&mut self) -> u64

Sends LIST_SUBSCRIPTIONS message.

Returns the message id. This should be used to match the request with a future response. Sent messages should not share the same message id.

You should expect the server to respond with a similar message.

{ "method": "LIST_SUBSCRIPTIONS", "params": [ <streams> ], "id": <id> }

pub fn close(self) -> Result<(), Error>

Trait Implementations

impl<T> AsMut<WebSocket<T>> for WebSocketState<T>

fn as_mut(&mut self) -> &mut WebSocket<T>

Converts this type into a mutable reference of the (usually inferred) input type.

impl<T> From<WebSocketState<T>> for WebSocket<T>

fn from(conn: WebSocketState<T>) -> WebSocket<T>

Converts to this type from the input type.