Crates.io | crypto-ws-client |
lib.rs | crypto-ws-client |
version | 4.12.11 |
source | src |
created_at | 2020-12-28 22:43:35.214055 |
updated_at | 2023-02-26 12:15:52.930301 |
description | A versatile websocket client that supports many cryptocurrency exchanges. |
homepage | |
repository | https://github.com/crypto-crawler/crypto-crawler-rs/tree/main/crypto-ws-client |
max_upload_size | |
id | 328471 |
size | 353,510 |
A versatile websocket client that supports many cryptocurrency exchanges.
use crypto_ws_client::{BinanceSpotWSClient, WSClient};
#[tokio::main]
async fn main() {
let (tx, rx) = std::sync::mpsc::channel();
tokio::task::spawn(async move {
let symbols = vec!["BTCUSDT".to_string(), "ETHUSDT".to_string()];
let ws_client = BinanceSpotWSClient::new(tx, None).await;
ws_client.subscribe_trade(&symbols).await;
// run for 5 seconds
let _ = tokio::time::timeout(std::time::Duration::from_secs(5), ws_client.run()).await;
ws_client.close();
});
for msg in rx {
println!("{}", msg);
}
}