ringline 0.1.2

Async I/O runtime with io_uring (Linux) and mio (cross-platform) backends
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

use std::io::{self, BufRead, Read, Write};
use std::net::TcpStream;

fn main() {
    let addr = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "127.0.0.1:7878".to_string());

    let mut stream = TcpStream::connect(&addr).expect("failed to connect");
    eprintln!("connected to {addr}");

    let stdin = io::stdin();
    for line in stdin.lock().lines() {
        let line = line.expect("failed to read stdin");
        stream.write_all(line.as_bytes()).expect("failed to send");
        stream.write_all(b"\n").expect("failed to send newline");

        let mut buf = vec![0u8; line.len() + 1];
        stream
            .read_exact(&mut buf)
            .expect("failed to read response");
        print!("{}", String::from_utf8_lossy(&buf));
    }
}