Struct cooks::Cooks

pub struct Cooks<Txty, Rxty, F> {
    // some fields omitted
}

Methods

impl<Txty: Send, Rxty: Send, F> Cooks<Txty, Rxty, F> where F: Fn(Txty) -> Option<Rxty>, F: Send + Sync + 'static

fn new(f: F) -> Cooks<Txty, Rxty, F>

Starts new num_cpus cooks.

fn new_n(count: usize, f: F) -> Cooks<Txty, Rxty, F>

Starts new n cooks.

fn cook<'a, T>(&'a mut self, it: T) -> Dishes<'a, Txty, Rxty, T, F> where T: Iterator<Item=Txty>

fn cook_vec(&mut self, vec: Vec<Txty>) -> Vec<Option<Rxty>>

Trait Implementations

impl<Txty: Send, Rxty: Send, F> Drop for Cooks<Txty, Rxty, F>

fn drop(&mut self)