Struct IdentityWithResult

pub struct IdentityWithResult<Input, Error> { /* private fields */ }

An identity reducer for those who want to use Stepwise or in_parallel() without the use of non-threaded reduction of products created in threads.

Trait Implementations

impl<Input, Error> Default for IdentityWithResult<Input, Error>

fn default() -> Self

Returns the “default value” for a type.

impl<Input, Error> Reduce for IdentityWithResult<Input, Error>

type Input = Result<Input, <IdentityWithResult<Input, Error> as Reduce>::Error>

The type fed to the reducer in the feed() method.

type FeedProduce = Input

The type produced in Ok(…) by feed(). Most reducers by nature use () here as the value is in the aggregation. However, some may use it to collect statistics only and return their Input in some form as a result here for Stepwise to be useful.

type Output = ()

The type produced once by the finalize() method.

type Error = Error

The error type to use for all methods of this trait.

fn feed(&mut self, item: Self::Input) -> Result<Self::FeedProduce, Self::Error>

Called each time a new item was produced in order to aggregate it into the final result.

fn finalize(self) -> Result<Self::Output, Self::Error>

Called once once all items where passed to feed(), producing the final Output of the operation or an Error.