Struct BytesSource 

pub struct BytesSource { /* private fields */ }

A source for a bytes value.

Implementations

impl BytesSource

pub fn new(data: Bytes) -> Self

Creates a new bytes source from a bytes values.

pub fn with_offset(data: Bytes, offset: Pos) -> Self

Creates a new bytes source with an explicit offset.

When this function is used to create a bytes source, Source::pos will report a value increates by offset.

pub fn len(&self) -> usize

Returns the remaining length of data.

pub fn is_empty(&self) -> bool

Returns whether there is any data remaining.

pub fn split_to(&mut self, len: usize) -> Bytes

Splits the first len bytes off the source and returns them.

Panics

This method panics of len is larger than self.len().

pub fn into_bytes(self) -> Bytes

Converts the source into the remaining bytes.

Trait Implementations

impl Clone for BytesSource

fn clone(&self) -> BytesSource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BytesSource

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

Formats the value using the given formatter.

impl Source for BytesSource

type Error = Infallible

The error produced when the source failed to read more data.

fn pos(&self) -> Pos

Returns the current logical postion within the sequence of data.

fn request(&mut self, _len: usize) -> Result<usize, Self::Error>

Request at least len bytes to be available.

fn slice(&self) -> &[u8]

Returns a bytes slice with the available data.

fn bytes(&self, start: usize, end: usize) -> Bytes

Produces a Bytes value from part of the data.

fn advance(&mut self, len: usize)

Advance the source by len bytes.

fn skip(&mut self, len: usize) -> Result<usize, Self::Error>

Skip over the next len bytes.

fn take_u8(&mut self) -> Result<u8, DecodeError<Self::Error>>

Takes a single octet from the source.

fn take_opt_u8(&mut self) -> Result<Option<u8>, Self::Error>

Takes an optional octet from the source.

fn content_err(&self, err: impl Into<ContentError>) -> DecodeError<Self::Error>

Returns a content error at the current position of the source.