Struct WebSocketSpotStream 

pub struct WebSocketSpotStream { /* private fields */ }

Implementations

impl WebSocketSpotStream

pub fn new_with_shared_handler( handler: Arc<Mutex<Box<dyn FnMut(WebsocketSpotEvent) -> Result<()> + Send + Sync + 'static>>>, ) -> Self

Construct and start background task immediately.

• handler is the callback for incoming events. Should be wrapped into Arc + Mutex + Box

pub fn new<Callback>(handler: Callback) -> Self

where Callback: FnMut(WebsocketSpotEvent) -> Result<()> + Send + Sync + 'static,

Construct and start background task immediately.

• handler is the callback for incoming events.

pub async fn subscribe(&self, streams: Vec<String>) -> Result<()>

Subscribe to a stream

pub async fn unsubscribe(&self, streams: Vec<String>) -> Result<()>

Unsubscribe from a stream

pub async fn list_subscriptions(&self) -> Result<Vec<String>>

Subscribe to a stream

pub async fn shutdown(&self) -> Result<()>

Ask the actor to shut down. Optionally you can await the join handle after this.

pub async fn wait_for_end(self) -> Result<()>

If you want, you can provide a method to wait for the actor to finish.

pub async fn reconnect(&mut self) -> Result<()>

Implementation that creates an entirely new WebSocketSpotStream instance and replaces self with it.