[−][src]Struct hyper::server::conn::Http
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
[src]
impl Http
pub fn new() -> Http
[src]
pub fn new() -> Http
Creates a new instance of the HTTP protocol, ready to spawn a server or start accepting connections.
impl<E> Http<E>
[src]
impl<E> Http<E>
pub fn http1_only(&mut self, val: bool) -> &mut Self
[src]
pub fn http1_only(&mut self, val: bool) -> &mut Self
Sets whether HTTP1 is required.
Default is false
pub fn http1_writev(&mut self, val: bool) -> &mut Self
[src]
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
.
pub fn http2_only(&mut self, val: bool) -> &mut Self
[src]
pub fn http2_only(&mut self, val: bool) -> &mut Self
Sets whether HTTP2 is required.
Default is false
pub fn keep_alive(&mut self, val: bool) -> &mut Self
[src]
pub fn keep_alive(&mut self, val: bool) -> &mut Self
Enables or disables HTTP keep-alive.
Default is true.
pub fn max_buf_size(&mut self, max: usize) -> &mut Self
[src]
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.
pub fn pipeline_flush(&mut self, enabled: bool) -> &mut Self
[src]
pub fn pipeline_flush(&mut self, enabled: bool) -> &mut Self
Aggregates flushes to better support pipelined responses.
Experimental, may have bugs.
Default is false.
pub fn with_executor<E2>(self, exec: E2) -> Http<E2>
[src]
pub fn with_executor<E2>(self, exec: E2) -> Http<E2>
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, E> where
S: Service<ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
I: AsyncRead + AsyncWrite,
E: H2Exec<S::Future, Bd>,
[src]
pub fn serve_connection<S, I, Bd>(
&self,
io: I,
service: S
) -> Connection<I, S, E> where
S: Service<ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
I: AsyncRead + AsyncWrite,
E: H2Exec<S::Future, Bd>,
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,
make_service: S
) -> Result<Serve<AddrIncoming, S, E>> where
S: MakeServiceRef<AddrStream, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
[src]
pub fn serve_addr<S, Bd>(
&self,
addr: &SocketAddr,
make_service: S
) -> Result<Serve<AddrIncoming, S, E>> where
S: MakeServiceRef<AddrStream, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
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
make_service
object provided, creating a new service per
connection.
pub fn serve_addr_handle<S, Bd>(
&self,
addr: &SocketAddr,
handle: &Handle,
make_service: S
) -> Result<Serve<AddrIncoming, S, E>> where
S: MakeServiceRef<AddrStream, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
[src]
pub fn serve_addr_handle<S, Bd>(
&self,
addr: &SocketAddr,
handle: &Handle,
make_service: S
) -> Result<Serve<AddrIncoming, S, E>> where
S: MakeServiceRef<AddrStream, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
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
make_service
object provided, creating a new service per
connection.
pub fn serve_incoming<I, S, Bd>(
&self,
incoming: I,
make_service: S
) -> Serve<I, S, E> where
I: Stream,
I::Error: Into<Box<dyn Error + Send + Sync>>,
I::Item: AsyncRead + AsyncWrite,
S: MakeServiceRef<I::Item, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
[src]
pub fn serve_incoming<I, S, Bd>(
&self,
incoming: I,
make_service: S
) -> Serve<I, S, E> where
I: Stream,
I::Error: Into<Box<dyn Error + Send + Sync>>,
I::Item: AsyncRead + AsyncWrite,
S: MakeServiceRef<I::Item, ReqBody = Body, ResBody = Bd>,
S::Error: Into<Box<dyn Error + Send + Sync>>,
Bd: Payload,
E: H2Exec<<S::Service as Service>::Future, Bd>,
Bind the provided stream of incoming IO objects with a MakeService
.
Trait Implementations
impl<E: Clone> Clone for Http<E>
[src]
impl<E: Clone> Clone for Http<E>
fn clone(&self) -> Http<E>
[src]
fn clone(&self) -> Http<E>
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
impl<E: Debug> Debug for Http<E>
[src]
impl<E: Debug> Debug for Http<E>
Auto Trait Implementations
Blanket Implementations
impl<T> From for T
[src]
impl<T> From for T
impl<T, U> Into for T where
U: From<T>,
[src]
impl<T, U> Into for T where
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
impl<T, U> TryFrom for T where
T: From<U>,
[src]
impl<T, U> TryFrom for T where
T: From<U>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
impl<T> Borrow for T where
T: ?Sized,
[src]
impl<T> Borrow for T where
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
impl<T> Any for T where
T: 'static + ?Sized,
fn get_type_id(&self) -> TypeId
[src]
fn get_type_id(&self) -> TypeId
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
try_from
)The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
impl<T> BorrowMut for T where
T: ?Sized,
[src]
impl<T> BorrowMut for T where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
fn borrow_mut(&mut self) -> &mut T
impl<T> Erased for T
impl<T> Erased for T