Struct UpgradeableConnection

pub struct UpgradeableConnection<T, S>
where
    S: HttpService<Incoming>,
{ /* private fields */ }

A future binding a connection with a Service with Upgrade support.

Implementations

impl<I, B, S> UpgradeableConnection<I, S>

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>>,

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.

Trait Implementations

impl<I, B, S> Future for UpgradeableConnection<I, S>

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

type Output = Result<(), Error>

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.