Trait rocket::http::hyper::net::NetworkConnector

pub trait NetworkConnector {
    type Stream: Into<Box<dyn NetworkStream + 'static + Send>>;
    fn connect(
        &self, 
        host: &str, 
        port: u16, 
        scheme: &str
    ) -> Result<Self::Stream, Error>;
}

A connector creates a NetworkStream.

Associated Types

type Stream: Into<Box<dyn NetworkStream + 'static + Send>>

Type of Stream to create

Loading content...

Required methods

fn connect(
    &self,
    host: &str,
    port: u16,
    scheme: &str
) -> Result<Self::Stream, Error>

Connect to a remote address.

Loading content...

Implementations on Foreign Types

impl<C, S> NetworkConnector for Pool<C> where
    C: NetworkConnector<Stream = S>,
    S: NetworkStream + Send, 

type Stream = PooledStream<S>

fn connect(
    &self,
    host: &str,
    port: u16,
    scheme: &str
) -> Result<PooledStream<S>, Error>

Loading content...

Implementors

impl NetworkConnector for HttpConnector

type Stream = HttpStream

fn connect(
    &self,
    host: &str,
    port: u16,
    scheme: &str
) -> Result<HttpStream, Error>

impl<F> NetworkConnector for F where
    F: Fn(&str, u16, &str) -> Result<TcpStream, Error>, 

A closure as a connector used to generate TcpStreams per request

Example

Basic example:

Client::with_connector(|addr: &str, port: u16, scheme: &str| {
    TcpStream::connect(&(addr, port))
});

Example using TcpBuilder from the net2 crate if you want to configure your source socket:

Client::with_connector(|addr: &str, port: u16, scheme: &str| {
    let b = try!(TcpBuilder::new_v4());
    try!(b.bind("127.0.0.1:0"));
    b.connect(&(addr, port))
});

type Stream = HttpStream

fn connect(
    &self,
    host: &str,
    port: u16,
    scheme: &str
) -> Result<HttpStream, Error>

impl<S, C> NetworkConnector for HttpsConnector<S, C> where
    C: NetworkConnector<Stream = HttpStream>,
    S: SslClient<HttpStream>, 

type Stream = HttpsStream<<S as SslClient<HttpStream>>::Stream>

fn connect(
    &self,
    host: &str,
    port: u16,
    scheme: &str
) -> Result<<HttpsConnector<S, C> as NetworkConnector>::Stream, Error>

Loading content...