pub trait Source {
type OutputValue: Send;
type OutputError: Send;
// Required method
fn process(
&mut self,
output: &mut Sender<Message<Self::OutputValue, Self::OutputError>>,
stop: &mut bool,
);
}pub trait Source {
type OutputValue: Send;
type OutputError: Send;
// Required method
fn process(
&mut self,
output: &mut Sender<Message<Self::OutputValue, Self::OutputError>>,
stop: &mut bool,
);
}