Trait parallel_processor::buckets::readers::BucketReader

pub trait BucketReader {
    // Required methods
    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;
}

Required Methods

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

Implementors

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