Trait stack_queue::BackgroundQueue

pub trait BackgroundQueue: Send + Sync + Sized + 'static {
    type Task: Send + Sync + Sized + 'static;
    type impl_trait_batch_process_0<'async_trait, const N: usize>: Future<Output = ()> + 'async_trait + Send;

    // Required method
    fn batch_process<'async_trait, const N: usize>(
        tasks: UnboundedSlice<'async_trait, Self::Task, N>
    ) -> Self::impl_trait_batch_process_0<'async_trait, N>;

    // Provided method
    fn auto_batch<const N: usize>(task: Self::Task)
       where Self: LocalQueue<N, BufferCell = BufferCell<Self::Task>> { ... }
}

Fire and forget auto-batched queue

Required Associated Types

type Task: Send + Sync + Sized + 'static

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

Required Methods

fn batch_process<'async_trait, const N: usize>( tasks: UnboundedSlice<'async_trait, Self::Task, N> ) -> Self::impl_trait_batch_process_0<'async_trait, N>

Provided Methods

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

Implementors