pub trait Effector: Send + Sync {
// Required method
fn new_stream(&self, expr: &str, cap: usize) -> Box<dyn EffectorStream>;
}
pub trait Effector: Send + Sync {
// Required method
fn new_stream(&self, expr: &str, cap: usize) -> Box<dyn EffectorStream>;
}