pub trait TaskSource: Send {
type TaskInput: Clone + TaskData;
type Error: Error + Send + Sync + 'static;
// Required method
fn next_task(
&mut self,
id: Uuid,
) -> Result<Option<Self::TaskInput>, Self::Error>;
}pub trait TaskSource: Send {
type TaskInput: Clone + TaskData;
type Error: Error + Send + Sync + 'static;
// Required method
fn next_task(
&mut self,
id: Uuid,
) -> Result<Option<Self::TaskInput>, Self::Error>;
}