acw/async-socks5
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use GenericStream::from once, just to make sure it works.

Browse Source
This commit is contained in:
Adam Wick
2021-07-26 20:39:52 -07:00
parent 58cb384afd
commit 6bddd878fb
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/network/standard.rs
View File

@@ -98,7 +98,7 @@ impl Networklike for Builtin {
SOCKSv5Address::Name(n) => TcpStream::connect((n.as_str(), port)).await?, SOCKSv5Address::Name(n) => TcpStream::connect((n.as_str(), port)).await?,
}; };
Ok(GenericStream::new(base_stream)) Ok(GenericStream::from(base_stream))
} }
async fn listen<A: Send + Into<SOCKSv5Address>>( async fn listen<A: Send + Into<SOCKSv5Address>>(
@@ -179,6 +179,8 @@ fn check_sanity() {
let (sender_address, sender_port) = sender.local_addr(); let (sender_address, sender_port) = sender.local_addr();
let send_buffer = [0xa, 0xff, 0xab, 0x1e]; let send_buffer = [0xa, 0xff, 0xab, 0x1e];
sender.write_all(&send_buffer).await.expect("Couldn't send the write buffer"); sender.write_all(&send_buffer).await.expect("Couldn't send the write buffer");
sender.flush().await.expect("Couldn't flush the write buffer");
sender.close().await.expect("Couldn't close the write buffer");
(sender_address, sender_port) (sender_address, sender_port)
}); });