Struct SliceParallelSource

pub struct SliceParallelSource<'data, T> { /* private fields */ }

A parallel source over a slice. This struct is created by the par_iter() method on IntoParallelRefSource.

You most likely won’t need to interact with this struct directly, as it implements the ParallelSource and ParallelSourceExt traits, but it is nonetheless public because of the must_use annotation.

See also MutSliceParallelSource.

let input = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
let iter: SliceParallelSource<_> = input.par_iter();
let sum = iter.with_thread_pool(&mut thread_pool).sum::<i32>();
assert_eq!(sum, 5 * 11);

Trait Implementations

impl<'data, T: Sync> ParallelSource for SliceParallelSource<'data, T>

type Item = &'data T

The type of items that this parallel source produces.

fn descriptor(self) -> impl SourceDescriptor<Item = Self::Item> + Sync

Returns an object that describes how to fetch items from this source.