Struct async_read_length_limit::LengthLimit

pub struct LengthLimit<T> { /* private fields */ }

[AsyncRead] length limiter

Protects against a certain class of denial-of-service attacks wherein long chunked bodies are uploaded to web services.

The number of bytes will never be more than the provided byte limit. If the byte limit is exactly the length of the contained AsyncRead, it is considered an error.

Errors

This will return an error if the underlying AsyncRead does so or if the read length meets (or would exceed) the provided length limit. The returned std::io::Error will have an error kind of ErrorKind::InvalidData and a contained error of LengthLimitExceeded.

Implementations

impl<T> LengthLimit<T>

pub fn new(reader: T, max_bytes: usize) -> Self

Trait Implementations

impl<T: AsyncRead> AsyncRead for LengthLimit<T>

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

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.

impl<'__pin, T> Unpin for LengthLimit<T>where __Origin<'__pin, T>: Unpin,