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