Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

WebSocket client for streaming data from Webull.

Implementations

impl WebSocketClient

pub fn new(base_url: String, auth_manager: Arc<AuthManager>) -> Self

Create a new WebSocket client.

pub async fn connect(&mut self) -> WebullResult<Receiver<Event>>

Connect to the WebSocket server.

pub async fn disconnect(&mut self) -> WebullResult<()>

Disconnect from the WebSocket server.

pub async fn subscribe(&self, request: SubscriptionRequest) -> WebullResult<()>

Subscribe to a topic.

pub async fn unsubscribe( &self, request: UnsubscriptionRequest, ) -> WebullResult<()>

Unsubscribe from a topic.