Struct ReadBatch 

pub struct ReadBatch<T> { /* private fields */ }

Implementations

impl ReadBatch<FileEvent>

pub fn event(&self) -> &FileEvent

pub fn data(&self) -> Option<&[u8]>

pub fn offset(&self) -> Option<u64>

impl<T> ReadBatch<T>

pub fn new(value: T) -> ReadBatch<T>

pub fn try_map<U, E>( self, map: impl FnOnce(T) -> Result<U, E>, ) -> Result<ReadBatch<U>, E>

where E: From<Error>,

Moves A Unique Batch Through A Fallible Projection.

pub fn try_map_with<U, V, E>( self, other: ReadBatch<U>, map: impl FnOnce(T, U) -> Result<V, E>, ) -> Result<ReadBatch<V>, E>

where E: From<Error>,

pub fn owner(&self) -> Arc<impl Borrow<T> + Send + Sync + 'static>

where T: Send + Sync + 'static,

Trait Implementations

impl<T> AsRef<T> for ReadBatch<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.

impl<T> Clone for ReadBatch<T>

fn clone(&self) -> ReadBatch<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for ReadBatch<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Deref for ReadBatch<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &<ReadBatch<T> as Deref>::Target

Dereferences the value.

impl<T> MemorySize for ReadBatch<T>

where T: MemorySize,

fn memory_size(&self) -> usize

const INLINE_ONLY: bool = false

True only when every value occupies exactly size_of::<Self>() bytes, with no separately owned allocations or additional accounting charge.