Trait stack_queue::TaskQueue

pub trait TaskQueue: Send + Sync + Sized + 'static {
    type Task: Send + Sync + Sized + 'static;
    type Value: Send;
    type impl_trait_batch_process_0<'async_trait, const N: usize>: Future<Output = CompletionReceipt<Self>> + 'async_trait + Send;

    fn batch_process<'async_trait, const N: usize>(
        assignment: PendingAssignment<'async_trait, Self, N>
    ) -> Self::impl_trait_batch_process_0<'async_trait, N>;

    fn auto_batch<const N: usize>(task: Self::Task) -> AutoBatchedTask<Self, N> 
    where
        Self: LocalQueue<N, BufferCell = TaskRef<Self>>,
    { ... }
}

Auto-batched queue whereby each task resolves to a value

Required Associated Types

type Task: Send + Sync + Sized + 'static

type Value: Send

type impl_trait_batch_process_0<'async_trait, const N: usize>: Future<Output = CompletionReceipt<Self>> + 'async_trait + Send

Required Methods

fn batch_process<'async_trait, const N: usize>(
    assignment: PendingAssignment<'async_trait, Self, N>
) -> Self::impl_trait_batch_process_0<'async_trait, N>

Provided Methods

fn auto_batch<const N: usize>(task: Self::Task) -> AutoBatchedTask<Self, N> where
    Self: LocalQueue<N, BufferCell = TaskRef<Self>>,

Implementors