boomnet 0.0.78

Framework for building low latency clients on top of TCP.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use crate::common::TradeEndpoint;
use boomnet::service::IntoIOService;
use boomnet::service::select::mio::MioSelector;

#[path = "common/mod.rs"]
mod common;

fn main() -> anyhow::Result<()> {
    env_logger::init();

    let mut io_service = MioSelector::new()?.into_io_service();

    let endpoint_xrp = TradeEndpoint::new_with_subscribe(2, "wss://stream3.binance.com:443/ws", None, "xrpusdt", false);

    let handle = io_service.register(endpoint_xrp)?;

    // we delay the subscription until the endpoint is ready
    loop {
        let success = io_service.dispatch(handle, |ws, endpoint| {
            endpoint.subscribe(ws)?;
            Ok(())
        })?;
        if success.is_some() {
            break;
        } else {
            io_service.poll(|ws, endpoint| endpoint.poll(ws))?;
        }
    }

    loop {
        io_service.poll(|ws, endpoint| endpoint.poll(ws))?;
    }
}