tokio_smux 0.2.0

Smux protocol in Rust. Provide multiplexing for reliable 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

use tokio::net::TcpStream;
use tokio_smux::{Session, SmuxConfig};

#[tokio::main]
async fn main() {
  let client = TcpStream::connect("127.0.0.1:3100").await.unwrap();

  let mut session = Session::client(client, SmuxConfig::default()).unwrap();

  let mut stream = session.open_stream().await.unwrap();

  let data: Vec<u8> = vec![0; 65535];
  stream.send_message(data).await.unwrap();

  let msg = stream.recv_message().await.unwrap();

  if msg.is_none() {
    println!("stream fin");
    return;
  }

  println!("receive {} bytes", msg.unwrap().len())
}