Struct jpeg_decoder::worker::multithreaded::MpscWorker

pub struct MpscWorker {
    senders: [Option<Sender<WorkerMsg>>; 4],
}

Fields

senders: [Option<Sender<WorkerMsg>>; 4]

Implementations

impl MpscWorker

fn start_with( &mut self, row_data: RowData, spawn_worker: impl FnOnce(usize) -> Result<Sender<WorkerMsg>, Error>, ) -> Result<(), Error>

fn append_row(&mut self, row: (usize, Vec<i16>)) -> Result<(), Error>

fn get_result_with( &mut self, index: usize, collect: impl FnOnce(Receiver<Vec<u8>>) -> Vec<u8>, ) -> Result<Vec<u8>, Error>

Trait Implementations

impl Default for MpscWorker

fn default() -> MpscWorker

Returns the “default value” for a type.

impl Worker for MpscWorker

fn start(&mut self, row_data: RowData) -> Result<(), Error>

fn append_row(&mut self, row: (usize, Vec<i16>)) -> Result<(), Error>

fn get_result(&mut self, index: usize) -> Result<Vec<u8>, Error>

fn append_rows( &mut self, row: &mut dyn Iterator<Item = (usize, Vec<i16>)>, ) -> Result<(), Error>

Default implementation for spawning multiple tasks.