forward 0.1.0-alpha.1

open a TCP port and foward all trafics through a proxy to another server or port
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::io;
use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};

pub async fn pipe<R, W>(mut read: R, mut write: W) -> io::Result<()>
where
    R: AsyncRead + Unpin,
    W: AsyncWrite + Unpin,
{
    println!("[client] client => here => proxy => server: start");
    let mut buf = [0; 4096];
    loop {
        let n = read.read(&mut buf).await?;
        if n <= 0 {
            break;
        }

        write.write_all(&mut buf[..n]).await?;
    }
    println!("[client] client => here => proxy => server: end");
    Ok(())
}