Struct stack_queue::assignment::TaskAssignment

pub struct TaskAssignment<'a, T: TaskQueue, const N: usize> { /* private fields */ }

Assignment of a task range yet to be processed

Implementations

impl<'a, T, const N: usize> TaskAssignment<'a, T, N>where
    T: TaskQueue,

pub fn tasks(&self) -> &[TaskRef<T>]

A slice of the assigned task range

pub fn resolve_with_iter<I>(self, iter: I) -> CompletionReceipt<T>where
    I: IntoIterator<Item = T::Value>,

Resolve task assignment with an iterator where indexes align with tasks

pub fn map<F>(self, op: F) -> CompletionReceipt<T>where
    F: Fn(T::Task) -> T::Value + Sync,

Resolve task assignment by mapping each task into it’s respective value

pub async fn with_blocking<F>(self, f: F) -> CompletionReceipt<T>where
    F: for<'b> FnOnce(TaskAssignment<'b, T, N>) -> CompletionReceipt<T> + Send + 'static,

Move TaskAssignment into a thread where blocking is acceptable

Trait Implementations

impl<'a, T, const N: usize> Drop for TaskAssignment<'a, T, N>where
    T: TaskQueue,

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, T, const N: usize> Send for TaskAssignment<'a, T, N>where
    T: TaskQueue,

impl<'a, T, const N: usize> Sync for TaskAssignment<'a, T, N>where
    T: TaskQueue,