TaskSource

Trait TaskSource 

Source
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>;
}

Required Associated Types§

Required Methods§

Source

fn next_task( &mut self, id: Uuid, ) -> Result<Option<Self::TaskInput>, Self::Error>

Implementors§