ruchei 0.1.2

Utilities for working with many streams
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

//! Read many messages.

use std::{pin::pin, time::Instant};

use async_std::stream::StreamExt;

#[async_std::main]
async fn main() {
    let mut stream = pin!(
        async_tungstenite::client_async(
            "ws://127.0.0.1:8080/",
            async_net::TcpStream::connect("127.0.0.1:8080")
                .await
                .unwrap()
        )
        .await
        .unwrap()
        .0
    );
    stream.next().await.unwrap().unwrap();
    let start = Instant::now();
    for _ in 1..1_000_000 {
        stream.next().await.unwrap().unwrap();
    }
    println!("{:?}", start.elapsed());
}