Struct parallel_processor::buckets::readers::generic_binary_reader::GenericChunkedBinaryReader

pub struct GenericChunkedBinaryReader<D: ChunkDecoder> { /* private fields */ }

Implementations

impl<D: ChunkDecoder> GenericChunkedBinaryReader<D>

pub fn new( name: impl AsRef<Path>, remove_file: RemoveFileMode, prefetch_amount: Option<usize> ) -> Self

pub fn get_length(&self) -> usize

pub fn get_chunks_count(&self) -> usize

pub fn is_finished(&self) -> bool

pub fn get_single_stream<'a>(&'a mut self) -> impl Read + 'a

pub fn get_read_parallel_stream(&self) -> Option<impl Read>

pub fn decode_bucket_items_parallel<S: BucketItemSerializer, F: for<'a> FnMut(S::ReadType<'a>, &mut S::ExtraDataBuffer)>( &self, buffer: S::ReadBuffer, extra_buffer: S::ExtraDataBuffer, func: F ) -> bool

Trait Implementations

impl<D: ChunkDecoder> BucketReader for GenericChunkedBinaryReader<D>

fn decode_all_bucket_items<S: BucketItemSerializer, F: for<'a> FnMut(S::ReadType<'a>, &mut S::ExtraDataBuffer)>( self, buffer: S::ReadBuffer, extra_buffer: &mut S::ExtraDataBuffer, func: F )

fn get_name(&self) -> PathBuf

impl<D: ChunkDecoder> Drop for GenericChunkedBinaryReader<D>

fn drop(&mut self)

Executes the destructor for this type.

impl<D: ChunkDecoder> Sync for GenericChunkedBinaryReader<D>