pub trait BuilderTask<TYPES: NodeType>: Send + Sync {
// Required method
fn start(
self: Box<Self>,
stream: Box<dyn Stream<Item = Event<TYPES>> + Unpin + Send + 'static>,
);
}pub trait BuilderTask<TYPES: NodeType>: Send + Sync {
// Required method
fn start(
self: Box<Self>,
stream: Box<dyn Stream<Item = Event<TYPES>> + Unpin + Send + 'static>,
);
}