Struct parallel_processor::buckets::readers::async_binary_reader::AsyncBinaryReader

pub struct AsyncBinaryReader { /* private fields */ }

Implementations

impl AsyncBinaryReader

pub fn new( path: &PathBuf, compressed: bool, remove_file: RemoveFileMode, prefetch: Option<usize> ) -> Self

pub fn get_chunks_count(&self) -> usize

pub fn get_file_size(&self) -> usize

impl AsyncBinaryReader

pub fn is_finished(&self) -> bool

pub fn get_items_stream<S: BucketItemSerializer>( &self, read_thread: Arc<AsyncReaderThread>, buffer: S::ReadBuffer, extra_buffer: S::ExtraDataBuffer ) -> AsyncBinaryReaderItemsIterator<S>

pub fn get_name(&self) -> PathBuf

Trait Implementations

impl Clone for AsyncBinaryReader

fn clone(&self) -> AsyncBinaryReader

Returns a copy of the value.

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

Performs copy-assignment from source.