Struct ReadBuf

pub struct ReadBuf<S> {
    pub in_buf: Buf,
    /* private fields */
}

An input counterpart of IoBuf when the latter is split

Fields

in_buf: Buf

Implementations

impl<S> ReadBuf<S>

pub fn read(&mut self) -> Result<usize, Error>

where S: AsyncRead,

Read a chunk of data into a buffer

The data just read can then be found in self.in_buf.

This method does just one read. Because you are ought to try parse request after every read rather than reading a lot of the data in memory.

This method returns 0 when no bytes are read, both when WouldBlock occurred and when connection has been closed. You may then use self.done() to distinguish from these conditions.

Note: this method silently assumes that you will call it on poll every time until self.done() returns false. I.e. it behaves as Async method but does’t return Async value to allow simpler handling

pub fn done(&self) -> bool

Returns true when connection is closed by peer

Note: this method returns false and schedules a wakeup if connecion is currently locked

pub fn framed<D: Decode>(self, codec: D) -> ReadFramed<S, D>

Trait Implementations

impl<S> Debug for ReadBuf<S>

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

Formats the value using the given formatter.