Struct Input 

pub struct Input { /* private fields */ }

The connection’s read buffer: a zero-copy view of what was read and not yet consumed.

let mut input = net_io::Input::from_bytes(b"GET / HTTP/1.1\r\n");
assert_eq!(input.bytes(), b"GET / HTTP/1.1\r\n");
input.consume(4);
assert_eq!(input.bytes(), b"/ HTTP/1.1\r\n");

Implementations

impl Input

pub fn from_bytes(bytes: &[u8]) -> Input

An input holding bytes, for tests of sessions (allocates).

pub fn bytes(&self) -> &[u8]

The unconsumed bytes.

pub fn consume(&mut self, n: usize)

Consumes n bytes (saturating at the length).

pub fn is_full(&self) -> bool

Whether the buffer is full: the session must consume or grow it.

pub fn class(&self) -> SizeClass

The buffer’s size class.

pub fn swap(&mut self, other: &mut Buffer) -> Result<(), SwapError>

Exchanges the read buffer with an empty other of the same class in O(1): other now holds the unconsumed bytes, and the connection reads into the buffer it was given.

Errors

SwapError::ClassMismatch, SwapError::NotEmpty.

use net_io::{BufferPool, Input};
let mut input = Input::from_bytes(b"body");
let mut pool = BufferPool::standalone(1 << 20);
let mut spare = pool.take(input.class()).unwrap();
input.swap(&mut spare).unwrap();
assert_eq!(spare.as_slice(), b"body");
assert!(input.bytes().is_empty());

Trait Implementations

impl Debug for Input

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

Formats the value using the given formatter.