crypto-ws-client

A versatile websocket client that supports many cryptocurrency exchanges.

Usage

use crypto_ws_client::{BinanceSpotWSClient, WSClient};

fn main() {
    let (tx, rx) = std::sync::mpsc::channel();
    let thread = std::thread::spawn(move || {
        for msg in rx {
            println!("{}", msg);
        }
    });
    let mut ws_client = BinanceSpotWSClient::new(tx, None);
    let channels = vec!["btcusdt@aggTrade".to_string(), "btcusdt@depth".to_string(),];
    ws_client.subscribe(&channels);
    ws_client.run(None);
    wc_client.close();
    drop(ws_client);
    thread.join().unwrap();
}

Contribution

How to add support for a new exchange

1. Add a new file under src/clients/

Define a struct in the file, with the same name as the file.

Define a channels_to_commands() function which can convert raw channels to subscribe/unsubscribe commands.

Define a customized on_misc_msg() to handle misc messages.

Use define_client! macro to implement the WSClient trait.

2. Add a new file under tests/

Add a new file under tests/ and put some integration tests in it.