Struct salvo::hyper::upgrade::Upgraded

pub struct Upgraded { /* fields omitted */ }

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.

Implementations

impl Upgraded

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

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

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

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for Upgraded

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

Attempt to write bytes from buf into the object.

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

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

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

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

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

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

pub fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Debug for Upgraded

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

Formats the value using the given formatter.