Struct BufferedMultiWorker 

pub struct BufferedMultiWorker<AllocU8: Allocator<u8>, AllocCommand: Allocator<StaticCommand>> {
    pub worker: MultiWorker<AllocU8, AllocCommand>,
    /* private fields */
}

Fields

worker: MultiWorker<AllocU8, AllocCommand>

Implementations

impl<AllocU8: Allocator<u8>, AllocCommand: Allocator<StaticCommand>> BufferedMultiWorker<AllocU8, AllocCommand>

pub fn new(mc: &mut AllocCommand) -> Self

pub fn free( &mut self, m8: &mut RepurposingAlloc<u8, AllocU8>, mc: &mut AllocCommand, )

Trait Implementations

impl<AllocU8: Allocator<u8>, AllocCommand: Allocator<StaticCommand>> ThreadToMain<AllocU8> for BufferedMultiWorker<AllocU8, AllocCommand>

const COOPERATIVE: bool = false

const ISOLATED: bool = true

fn pull_data(&mut self) -> ThreadData<AllocU8>

fn pull_context_map( &mut self, m8: Option<&mut RepurposingAlloc<u8, AllocU8>>, ) -> Result<PredictionModeContextMap<AllocatedMemoryPrefix<u8, AllocU8>>, ()>

fn push_cmd<Specialization: EncoderOrDecoderRecoderSpecialization>( &mut self, cmd: &mut Command<AllocatedMemoryPrefix<u8, AllocU8>>, _m8: Option<&mut RepurposingAlloc<u8, AllocU8>>, _recoder: Option<&mut DivansRecodeState<AllocU8::AllocatedMemory>>, _specialization: &mut Specialization, _output: &mut [u8], _output_offset: &mut usize, ) -> DivansOutputResult

fn push_consumed_data( &mut self, data: &mut AllocatedMemoryRange<u8, AllocU8>, _m8: Option<&mut RepurposingAlloc<u8, AllocU8>>, ) -> DivansOutputResult

fn push_eof(&mut self) -> DivansOutputResult

fn broadcast_err(&mut self, err: ErrMsg)