pub trait UnaryInputs<T>: ConditionallySendwhere
T: ConditionallySend,{
// Required methods
fn input(&mut self) -> &mut BoxStream<VPacket<T>>;
fn take_input(self) -> BoxStream<VPacket<T>>;
}
pub trait UnaryInputs<T>: ConditionallySendwhere
T: ConditionallySend,{
// Required methods
fn input(&mut self) -> &mut BoxStream<VPacket<T>>;
fn take_input(self) -> BoxStream<VPacket<T>>;
}