Enum servlin::internal::BodyAsyncReader

pub enum BodyAsyncReader<'x> {
    Cursor(Cursor<&'x [u8]>),
    EventReceiver(&'x Mutex<EventReceiver>),
    File(File),
}

Struct returned by RequestBody::async_reader and ResponseBody::async_reader.

Variants

Cursor(Cursor<&'x [u8]>)

EventReceiver(&'x Mutex<EventReceiver>)

File(File)

Implementations

impl<'x> BodyAsyncReader<'x>

pub fn bytes(bytes: &'x [u8]) -> Self

pub async fn file(path: impl AsRef<Path>) -> Result<BodyAsyncReader<'x>, Error>

Errors

Returns an error when it fails to open the file for reading.

Trait Implementations

impl<'x> AsyncRead for BodyAsyncReader<'x>

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

Attempt to read from the AsyncRead into buf.

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

Attempt to read from the AsyncRead into bufs using vectored IO operations.