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

//! Send once, receive forever.

use std::pin::pin;

use async_std::stream::StreamExt;
use futures_util::SinkExt;

#[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.send("hi".into()).await.unwrap();
    loop {
        let msg = stream.next().await.unwrap().unwrap();
        println!("{msg}");
    }
}