Trait stack_queue::BackgroundQueue

pub trait BackgroundQueue: Send + Sync + Sized + 'static {
    type Task: Send;

    fn batch_process<'async_trait, const N: usize>(
        tasks: UnboundedSlice<'async_trait, Self, N>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        Self: 'async_trait;

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

Fire and forget auto-batched queue

Required Associated Types

type Task: Send

Required Methods

fn batch_process<'async_trait, const N: usize>(
    tasks: UnboundedSlice<'async_trait, Self, N>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    Self: 'async_trait,

Provided Methods

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

Implementors