async_proxies::proxy

Trait AsyncProxy

Source 
pub trait AsyncProxy {
    type OutputStream: AsyncRead + AsyncWrite;
    type ErrorKind;
    type ConnParams;

    // Required methods
    fn connect<'life0, 'async_trait>(
        &'life0 mut self,
        params: Self::ConnParams,
    ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn write_buffer<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        buffer: &'life1 [u8],
        stream: Self::OutputStream,
    ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_buffer<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        buffer: &'life1 mut [u8],
        stream: Self::OutputStream,
    ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn drop_stream<'life0, 'async_trait>(
        &'life0 mut self,
        stream: Self::OutputStream,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::ErrorKind>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

This trait comes as an abstraction over proxy protocols. Each protocol serves own methods to establish connection between a proxy, you, and the destanation service. The same applies to I/O and closing the established connection

Required Associated Types§

Source

type OutputStream: AsyncRead + AsyncWrite

Source

type ErrorKind

Source

type ConnParams

Required Methods§

Source

fn connect<'life0, 'async_trait>( &'life0 mut self, params: Self::ConnParams, ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Connects to the destanation through proxy

Source

fn write_buffer<'life0, 'life1, 'async_trait>( &'life0 mut self, buffer: &'life1 [u8], stream: Self::OutputStream, ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Writes the buffer to the destanation

Source

fn read_buffer<'life0, 'life1, 'async_trait>( &'life0 mut self, buffer: &'life1 mut [u8], stream: Self::OutputStream, ) -> Pin<Box<dyn Future<Output = Result<Self::OutputStream, Self::ErrorKind>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reads buffer from the destanation

Source

fn drop_stream<'life0, 'async_trait>( &'life0 mut self, stream: Self::OutputStream, ) -> Pin<Box<dyn Future<Output = Result<(), Self::ErrorKind>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Drops the proxy stream

Implementors§