Struct async_socks5::SocksListener

pub struct SocksListener<S> { /* private fields */ }

A listener that accepts TCP connections through a proxy.

use async_socks5::SocksListener;
use tokio::{io::BufStream, net::TcpStream};

let stream = TcpStream::connect("my-proxy-server.com:54321").await?;
let mut stream = BufStream::new(stream);
let (stream, addr) = SocksListener::bind(stream, ("ftp-server.org", 21), None)
    .await?
    .accept()
    .await?;

Implementations

impl<S> SocksListener<S>

where S: AsyncWriteExt + AsyncReadExt + Send + Unpin,

pub async fn bind<A>(stream: S, addr: A, auth: Option<Auth>) -> Result<Self>

where A: Into<AddrKind>,

Creates SocksListener. Performs the BIND command under the hood.

pub fn proxy_addr(&self) -> &AddrKind

pub async fn accept(self) -> Result<(S, AddrKind)>

Trait Implementations

impl<S: Debug> Debug for SocksListener<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.