Struct BytesBufferer 

pub struct BytesBufferer { /* private fields */ }

Available on crate feature polars-io only.

Utility for byte buffering logic. Accepts both owned [Buffer<u8>] and borrowed &[u8] incoming bytes.

Implementations

impl BytesBufferer

pub fn new(config: &BytesBuffererConfig) -> BytesBufferer

pub fn stats(&self) -> BytesBuffererStats

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub fn push_owned(&mut self, bytes: &Buffer<u8>)

pub fn push_slice(&mut self, bytes: &[u8])

pub fn drain(&mut self) -> Drain<'_, Buffer<u8>>

Trait Implementations

impl IntoIterator for BytesBufferer

type Item = <Vec<Buffer<u8>> as IntoIterator>::Item

The type of the elements being iterated over.

type IntoIter = <Vec<Buffer<u8>> as IntoIterator>::IntoIter

Which kind of iterator are we turning this into?

fn into_iter(self) -> <BytesBufferer as IntoIterator>::IntoIter

Creates an iterator from a value.

impl WriteBytesOwned for BytesBufferer

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

fn write_all_owned(&mut self, bytes: &Buffer<u8>) -> Result<(), Error>

fn len(&self) -> usize