Struct channel_loader::SimpleLoader

pub struct SimpleLoader<T: SimpleWorker> { /* fields omitted */ }

convenience TaskHandler wrapper implementation useful for whenever task assignment cannot be deferred.

Trait Implementations

impl<T> Default for SimpleLoader<T> where
    T: SimpleWorker, 

fn default() -> Self

Returns the “default value” for a type.

impl<T> TaskHandler for SimpleLoader<T> where
    T: SimpleWorker, 

type Key = T::Key

type Value = T::Value

type Error = T::Error

const MAX_BATCH_SIZE: i32

fn handle_task<'async_trait>(
    task: Task<PendingAssignment<Self>>
) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>> where
    Self: 'async_trait,