pub trait Filter<From, To, R>: Consumer<From> + Provider<To, R> {
    // Required method
    fn worker(reader: Receiver<From>, tx: Sender<To>, options: RunOptions);
}

Required Methods§

source

fn worker(reader: Receiver<From>, tx: Sender<To>, options: RunOptions)

Implementors§