Struct rayon::split_producer::SplitProducer

pub(crate) struct SplitProducer<'p, P, V, const INCL: bool = false> {
    data: V,
    separator: &'p P,
    tail: usize,
}

Common producer for splitting on a predicate.

Fields

data: V

separator: &'p P

tail: usize

Marks the endpoint beyond which we’ve already found no separators.

Implementations

impl<'p, P, V> SplitProducer<'p, P, V>

where V: Fissile<P> + Send,

pub(crate) fn new(data: V, separator: &'p P) -> Self

impl<'p, P, V> SplitProducer<'p, P, V, true>

where V: Fissile<P> + Send,

pub(crate) fn new_incl(data: V, separator: &'p P) -> Self

impl<'p, P, V, const INCL: bool> SplitProducer<'p, P, V, INCL>

where V: Fissile<P> + Send,

pub(crate) fn fold_with<F>(self, folder: F, skip_last: bool) -> F

where F: Folder<V>,

Common fold_with implementation, integrating SplitTerminator’s need to sometimes skip its final empty item.

Trait Implementations

impl<'p, P, V, const INCL: bool> UnindexedProducer for SplitProducer<'p, P, V, INCL>

where V: Fissile<P> + Send, P: Sync,

type Item = V

The type of item returned by this producer.

fn split(self) -> (Self, Option<Self>)

Split midway into a new producer if possible, otherwise return None.

fn fold_with<F>(self, folder: F) -> F

where F: Folder<Self::Item>,

Iterate the producer, feeding each element to folder, and stop when the folder is full (or all elements have been consumed).