Struct hyper::upgrade::Upgraded

pub struct Upgraded {
    io: Rewind<Box<dyn Io + Send>>,
}

An upgraded HTTP connection.

This type holds a trait object internally of the original IO that was used to speak HTTP before the upgrade. It can be used directly as a Read or Write for convenience.

Alternatively, if the exact type is known, this can be deconstructed into its parts.

Fields

io: Rewind<Box<dyn Io + Send>>

Implementations

impl Upgraded

pub(crate) fn new<T>(io: T, read_buf: Bytes) -> Self

where T: AsyncRead + AsyncWrite + Unpin + Send + 'static,

pub fn downcast<T: AsyncRead + AsyncWrite + Unpin + 'static>( self, ) -> Result<Parts<T>, Self>

Tries to downcast the internal trait object to the type passed.

On success, returns the downcasted parts. On error, returns the Upgraded back.

Trait Implementations

impl AsyncRead for Upgraded

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for Upgraded

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

Like poll_write, except that it writes from a slice of buffers.

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

Attempts to flush the object, ensuring that any buffered data reach their destination.

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

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Debug for Upgraded

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

Formats the value using the given formatter.