Struct kayrx::web::multipart::dev::PayloadBuffer

pub struct PayloadBuffer {
    pub eof: bool,
    pub buf: BytesMut,
    // some fields omitted
}

Payload buffer

Fields

eof: bool

buf: BytesMut

Methods

impl PayloadBuffer

pub fn new<S>(stream: S) -> Self where
    S: Stream<Item = Result<Bytes, PayloadError>> + 'static, 

Create new PayloadBuffer instance

pub fn poll_stream(&mut self, cx: &mut Context) -> Result<(), PayloadError>

pub fn read_exact(&mut self, size: usize) -> Option<Bytes>

Read exact number of bytes

pub fn read_max(&mut self, size: u64) -> Result<Option<Bytes>, MultipartError>

pub fn read_until(
    &mut self,
    line: &[u8]
) -> Result<Option<Bytes>, MultipartError>

Read until specified ending

pub fn readline(&mut self) -> Result<Option<Bytes>, MultipartError>

Read bytes until new line delimiter

pub fn readline_or_eof(&mut self) -> Result<Option<Bytes>, MultipartError>

Read bytes until new line delimiter or eof

pub fn unprocessed(&mut self, data: Bytes)

Put unprocessed data back to the buffer