Trait RayonConsumer 

pub trait RayonConsumer {
    type Item: Send;

    // Required method
    fn consume(self, func: impl FnMut(Self::Item));
}

Tools for consume rayon iterator.

Required Associated Types

type Item: Send

Required Methods

fn consume(self, func: impl FnMut(Self::Item))

Use to immediately consume the data produced by the rayon iterator without waiting for all the data to be processed. The closures runs in the current thread.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<P, I> RayonConsumer for P

where P: ParallelIterator<Item = I>, I: Send,

type Item = I