Struct MessageMutParIter 

pub struct MessageMutParIter<'a, E>
where
    E: Message,
{ /* private fields */ }

A parallel iterator over Messages.

Implementations

impl<'a, E> MessageMutParIter<'a, E>

where E: Message,

pub fn new( mutator: &'a mut MessageCursor<E>, messages: &'a mut Messages<E>, ) -> MessageMutParIter<'a, E>

Creates a new parallel iterator over messages that have not yet been seen by mutator.

pub fn batching_strategy( self, strategy: BatchingStrategy, ) -> MessageMutParIter<'a, E>

Changes the batching strategy used when iterating.

For more information on how this affects the resultant iteration, see BatchingStrategy.

pub fn for_each<FN>(self, func: FN)

where FN: Fn(&'a mut E) + Send + Sync + Clone,

Runs the provided closure for each unread message in parallel.

Unlike normal iteration, the message order is not guaranteed in any form.

Panics

If the ComputeTaskPool is not initialized. If using this from a message reader that is being initialized and run from the ECS scheduler, this should never panic.

pub fn for_each_with_id<FN>(self, func: FN)

where FN: Fn(&'a mut E, MessageId<E>) + Send + Sync + Clone,

Runs the provided closure for each unread message in parallel, like for_each, but additionally provides the MessageId to the closure.

Note that the order of iteration is not guaranteed, but MessageIds are ordered by send order.

Panics

If the ComputeTaskPool is not initialized. If using this from a message reader that is being initialized and run from the ECS scheduler, this should never panic.

pub fn len(&self) -> usize

Returns the number of Messages to be iterated.

pub fn is_empty(&self) -> bool

Returns true if there are no messages remaining in this iterator.

Trait Implementations

impl<'a, E> Debug for MessageMutParIter<'a, E>

where E: Debug + Message,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'a, E> IntoIterator for MessageMutParIter<'a, E>

where E: Message,

type IntoIter = MessageMutIteratorWithId<'a, E>

Which kind of iterator are we turning this into?

type Item = <<MessageMutParIter<'a, E> as IntoIterator>::IntoIter as Iterator>::Item

The type of the elements being iterated over.

fn into_iter(self) -> <MessageMutParIter<'a, E> as IntoIterator>::IntoIter

Creates an iterator from a value.