Struct UserDataStreamManager 

pub struct UserDataStreamManager { /* private fields */ }

Manages a user data stream with automatic keep-alive.

This manager automatically refreshes the listen key every 30 minutes to prevent the stream from expiring (listen keys expire after 60 minutes).

Example

use binance_api_client::Binance;
use binance_api_client::websocket::UserDataStreamManager;

let client = Binance::new("api_key", "secret_key")?;
let mut manager = UserDataStreamManager::new(client).await?;

while let Some(event) = manager.next().await {
    match event? {
        WebSocketEvent::ExecutionReport(report) => {
            println!("Order update: {:?}", report);
        }
        WebSocketEvent::AccountPosition(position) => {
            println!("Account update: {:?}", position);
        }
        _ => {}
    }
}

Implementations

impl UserDataStreamManager

pub async fn new(client: Binance) -> Result<Self>

Create a new user data stream manager.

This will start the listen key and begin receiving user data events.

pub async fn next(&mut self) -> Option<Result<WebSocketEvent>>

Receive the next user data event.

pub async fn listen_key(&self) -> String

Get the current listen key.

pub fn stop(&self)

Stop the user data stream manager.

pub fn is_stopped(&self) -> bool

Check if the manager is stopped.