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 try_map<U, E>( self, additional_peak: usize, map: impl FnOnce(T) -> Result<U, E>, ) -> Result<ReadBatch<U>, E>

where E: From<Error>,

Consumes a unique owner and preserves its admitted memory through a projection.

additional_peak must bound all new output allocations and conversion scratch simultaneously live with the input. Private owner growth is admitted separately. The callback must transfer payload allocations only into its successful value. Errors and external captures must not retain them. Nested retained pages must retain or map their own owners.

Admission is nonblocking and happens before the callback. Shared owners are refused; failure consumes this handle. Existing and additional claims remain conservative until their last owner drops, including on independently shared memory claims. No automatic shrinking or payload cloning occurs.

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

where E: From<Error>,

Consumes two unique owners while retaining every input memory claim.

The callback has the same peak-allocation and payload-escape obligations as try_map. Guard-vector replacement and private owner growth are admitted separately before allocating. Admission never waits and failure consumes both handles. Shared or weak owner aliases are refused before the callback.

Combining claims does not unify their admission groups. Inputs used by later dependent reads should originate from the same ReadSession. Nested pages must continue to retain or map their own guards.

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.