Struct SocksListener

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

A listener that accepts TCP connections through a proxy.

use socks5_impl::client::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<UserKey>) -> Result<Self>

where A: Into<Address>,

Creates SocksListener. Performs the BIND command under the hood.

pub fn proxy_addr(&self) -> &Address

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

Trait Implementations

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

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

Formats the value using the given formatter.