SequentialFromParallelIterator

example.md

playground

seq_collect.rs

use rayon::iter::ParallelIterator;
use std::iter::FromIterator;

/// Unordered sequential collector
pub trait SequentialFromParallelIterator: ParallelIterator {
    fn seq_collect<R>(self, cap: usize) -> R
    where
        R: FromIterator<Self::Item>,
        R: Send,
    {
        rayon::scope(|scope| {
            let (sender, receiver) = crossbeam_channel::bounded(cap);
            scope.spawn(move |_| self.for_each(|item| sender.send(item).unwrap()));
            receiver.into_iter().collect()
        })
    }
}

impl<I> SequentialFromParallelIterator for I where I: ParallelIterator {}