Struct hyper_util::server::conn::auto::UpgradeableConnection

pub struct UpgradeableConnection<'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> UpgradeableConnection<'_, 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 UpgradeableConnection should continue to be polled until shutdown can finish.

Note

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

Trait Implementations

impl<I, S, E, B> Future for UpgradeableConnection<'_, 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 + Send + 'static, E: HttpServerConnExec<S::Future, B>,

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

The type of value produced on completion.

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

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

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

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