Struct hyper_util::server::conn::auto::Connection

pub struct Connection<'a, I, S, E>
where
    S: HttpService<Incoming>,
{ /* private fields */ }

Available on crate feature server and (crate features http1 or http2) only.

Connection future.

Implementations

impl<I, S, E, B> Connection<'_, I, S, E>

where S: HttpService<Incoming, ResBody = B>, S::Error: Into<Box<dyn StdError + Send + Sync>>, I: Read + Write + Unpin, B: Body + 'static, B::Error: Into<Box<dyn StdError + Send + Sync>>, E: HttpServerConnExec<S::Future, B>,

pub fn graceful_shutdown(self: Pin<&mut Self>)

Start a graceful shutdown process for this connection.

This Connection should continue to be polled until shutdown can finish.

Note

This should only be called while the Connection future is still pending. If called after Connection::poll has resolved, this does nothing.

pub fn into_owned(self) -> Connection<'static, I, S, E>

where Builder<E>: Clone,

Make this Connection static, instead of borrowing from Builder.

Trait Implementations

impl<I, S, E, B> Future for Connection<'_, I, S, E>

where S: Service<Request<Incoming>, Response = Response<B>>, S::Future: 'static, S::Error: Into<Box<dyn StdError + Send + Sync>>, B: Body + 'static, B::Error: Into<Box<dyn StdError + Send + Sync>>, I: Read + Write + Unpin + 'static, E: HttpServerConnExec<S::Future, B>,

type Output = Result<(), Box<dyn Error + Sync + Send>>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'a, I, B, S, E> GracefulConnection for Connection<'a, I, S, E>

where S: Service<Request<Incoming>, Response = Response<B>>, S::Error: Into<Box<dyn Error + Send + Sync>>, S::Future: 'static, I: Read + Write + Unpin + 'static, B: Body + 'static, B::Error: Into<Box<dyn Error + Send + Sync>>, E: Http2ServerConnExec<S::Future, B>,

Available on crate features server-graceful and server-auto only.

type Error = Box<dyn Error + Sync + Send>

The error type returned by the connection when used as a future.

fn graceful_shutdown(self: Pin<&mut Self>)

Start a graceful shutdown process for this connection.

impl<'__pin, 'a, I, S, E> Unpin for Connection<'a, I, S, E>

where __Origin<'__pin, 'a, I, S, E>: Unpin, S: HttpService<Incoming>,