Trait channel_loader::task::TaskHandler

pub trait TaskHandler: Default + Send + Sync {
    type Key: Key;
    type Value: Send + Clone + 'static;
    type Error: Send + Clone + 'static;

    const MAX_BATCH_SIZE: i32;

    #[must_use]
    fn handle_task<'async_trait>(
        task: Task<PendingAssignment<Self>>
    ) -> Pin<Box<dyn Future<Output = Task<CompletionReceipt<Self>>> + Send + 'async_trait>>
    where
        Self: 'async_trait;
}

A type-state control flow for driving tasks from assignment to completion. As task assignment can be deferred until connection acquisition and likewise loads batched by key, this enables opportunistic batching when connection acquisition becomes a bottleneck and also enables connection yielding as a consequence of work consolidation

Associated Types

type Key: Key

type Value: Send + Clone + 'static

type Error: Send + Clone + 'static

Associated Constants

const MAX_BATCH_SIZE: i32

Required methods

#[must_use]

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

Implementors

impl<T> TaskHandler for T where
    T: Default + DieselLoader + 'static, 

type Key = T::Key

type Value = T::Value

type Error = SimpleDieselError

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,