Struct hyper::server::conn::Http

pub struct Http { /* fields omitted */ }

A lower-level configuration of the HTTP protocol.

This structure is used to configure options for an HTTP server connection.

If you don't have need to manage connections yourself, consider using the higher-level Server API.

Methods

impl Http

pub fn new() -> Http

Creates a new instance of the HTTP protocol, ready to spawn a server or start accepting connections.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn http1_only(&mut self, val: bool) -> &mut Self

Sets whether HTTP1 is required.

Default is false

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn http1_writev(&mut self, val: bool) -> &mut Self

Set whether HTTP/1 connections should try to use vectored writes, or always flatten into a single buffer.

Note that setting this to false may mean more copies of body data, but may also improve performance when an IO transport doesn't support vectored writes well, such as most TLS implementations.

Default is true.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn http2_only(&mut self, val: bool) -> &mut Self

Sets whether HTTP2 is required.

Default is false

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn keep_alive(&mut self, val: bool) -> &mut Self

Enables or disables HTTP keep-alive.

Default is true.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn max_buf_size(&mut self, max: usize) -> &mut Self

Set the maximum buffer size for the connection.

Default is ~400kb.

Panics

The minimum value allowed is 8192. This method panics if the passed max is less than the minimum.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn pipeline_flush(&mut self, enabled: bool) -> &mut Self

Aggregates flushes to better support pipelined responses.

Experimental, may have bugs.

Default is false.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn executor<E>(&mut self, exec: E) -> &mut Self where     E: Executor<Box<Future<Item = (), Error = ()> + Send>> + Send + Sync + 'static,

Set the executor used to spawn background tasks.

Default uses implicit default (like tokio::spawn).

pub fn serve_connection<S, I, Bd>(&self, io: I, service: S) -> Connection<I, S> where     S: Service<ReqBody = Body, ResBody = Bd>,     S::Error: Into<Box<Error + Send + Sync>>,     S::Future: Send + 'static,     Bd: Payload,     I: AsyncRead + AsyncWrite,

Bind a connection together with a Service.

This returns a Future that must be polled in order for HTTP to be driven on the connection.

Example

let http = Http::new();
let conn = http.serve_connection(some_io, some_service);

let fut = conn.map_err(|e| {
    eprintln!("server connection error: {}", e);
});

hyper::rt::spawn(fut);

pub fn serve_addr<S, Bd>(     &self,     addr: &SocketAddr,     new_service: S ) -> Result<Serve<AddrIncoming, S>> where     S: NewService<ReqBody = Body, ResBody = Bd>,     S::Error: Into<Box<Error + Send + Sync>>,     Bd: Payload,

Bind the provided addr with the default Handle and return Serve.

This method will bind the addr provided with a new TCP listener ready to accept connections. Each connection will be processed with the new_service object provided, creating a new service per connection.

pub fn serve_addr_handle<S, Bd>(     &self,     addr: &SocketAddr,     handle: &Handle,     new_service: S ) -> Result<Serve<AddrIncoming, S>> where     S: NewService<ReqBody = Body, ResBody = Bd>,     S::Error: Into<Box<Error + Send + Sync>>,     Bd: Payload,

Bind the provided addr with the Handle and return a Serve

This method will bind the addr provided with a new TCP listener ready to accept connections. Each connection will be processed with the new_service object provided, creating a new service per connection.

pub fn serve_incoming<I, S, Bd>(     &self,     incoming: I,     new_service: S ) -> Serve<I, S> where     I: Stream,     I::Error: Into<Box<Error + Send + Sync>>,     I::Item: AsyncRead + AsyncWrite,     S: NewService<ReqBody = Body, ResBody = Bd>,     S::Error: Into<Box<Error + Send + Sync>>,     Bd: Payload,

Bind the provided stream of incoming IO objects with a NewService.

Trait Implementations

impl Clone for Http

fn clone(&self) -> Http

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Http

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

Formats the value using the given formatter.