Struct sea_streamer_file::ByteBuffer

pub struct ByteBuffer { /* private fields */ }

A FIFO queue of Bytes.

Implementations

impl ByteBuffer

pub fn new() -> Self

Create a new buffer.

pub fn one(bytes: Bytes) -> Self

Create a new buffer with one blob of bytes.

pub fn append(&mut self, bytes: Bytes)

Push bytes into the buffer.

pub fn size(&self) -> usize

Calculate the total number of bytes in the buffer.

pub fn is_empty(&self) -> bool

Return whether this buffer is empty.

pub fn clear(&mut self)

Clear all bytes from this buffer.

pub fn take(&mut self) -> Self

Take ownership of all bytes; leaving self Empty.

pub fn consume<T: Appendable>(&mut self, size: usize) -> T

Consume a specific number of bytes from the buffer, panic if there are not enough bytes.

impl ByteBuffer

IO methods

pub fn write_to(self, sink: &mut impl ByteSink) -> Result<usize, FileErr>

Trait Implementations

impl Appendable for ByteBuffer

fn append(&mut self, bytes: Bytes)

impl ByteSink for ByteBuffer

fn write(&mut self, bytes: Bytes) -> Result<(), FileErr>

This should never block.

impl ByteSource for ByteBuffer

type Future<'a> = Ready<Result<Bytes, FileErr>>

fn request_bytes(&mut self, size: usize) -> Self::Future<'_>

impl Clone for ByteBuffer

fn clone(&self) -> ByteBuffer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ByteBuffer

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

Formats the value using the given formatter.

impl Default for ByteBuffer

fn default() -> ByteBuffer

Returns the “default value” for a type.