Trait parallel_processor::buckets::readers::generic_binary_reader::ChunkDecoder

pub trait ChunkDecoder {
    type ReaderType: Read;

    const MAGIC_HEADER: &'static [u8; 16];

    // Required methods
    fn decode_stream(reader: FileReader, size: u64) -> Self::ReaderType;
    fn dispose_stream(stream: Self::ReaderType) -> FileReader ;
}

Required Associated Types

type ReaderType: Read

Required Associated Constants

const MAGIC_HEADER: &'static [u8; 16]

Required Methods

fn decode_stream(reader: FileReader, size: u64) -> Self::ReaderType

fn dispose_stream(stream: Self::ReaderType) -> FileReader

Implementors

impl ChunkDecoder for CompressedStreamDecoder

const MAGIC_HEADER: &'static [u8; 16] = COMPRESSED_BUCKET_MAGIC

type ReaderType = VecReader<Decoder<FileReader>>

impl ChunkDecoder for LockFreeStreamDecoder

const MAGIC_HEADER: &'static [u8; 16] = LOCK_FREE_BUCKET_MAGIC

type ReaderType = Take<FileReader>

impl ChunkDecoder for UnbufferedCompressedStreamDecoder

const MAGIC_HEADER: &'static [u8; 16] = COMPRESSED_BUCKET_MAGIC

type ReaderType = Decoder<FileReader>