com.cognitect.transducers

Class Impl

java.lang.Object

com.cognitect.transducers.Impl

public class Impl
extends Object

Helper functions used to implement transducers.

Constructor Summary

Constructors

Constructor and Description
Impl()

Method Summary

Methods

Modifier and Type	Method and Description
static <R,T> R	reduce(IReducingFunction<R,? super T> f, R result, Iterable<T> input) Applies given reducing function to current result and each T in input, using the result returned from each reduction step as input to the next step.
static <R,T> R	reduce(IReducingFunction<R,? super T> f, R result, Iterable<T> input, AtomicBoolean reduced) Applies given reducing function to current result and each T in input, using the result returned from each reduction step as input to the next step.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Impl

public Impl()

Method Detail

reduce

public static <R,T> R reduce(IReducingFunction<R,? super T> f,
             R result,
             Iterable<T> input)

Applies given reducing function to current result and each T in input, using the result returned from each reduction step as input to the next step. Returns final result.

Type Parameters:

R - the type of the result

T - the type of each item in input

Parameters:

f - a reducing function

result - an initial result value

input - the input to process

Returns:

the final reduced result

reduce

public static <R,T> R reduce(IReducingFunction<R,? super T> f,
             R result,
             Iterable<T> input,
             AtomicBoolean reduced)

Applies given reducing function to current result and each T in input, using the result returned from each reduction step as input to the next step. Returns final result.

Type Parameters:

R - the type of the result

T - the type of each item in input

Parameters:

f - a reducing function

result - an initial result value

input - the input to process

reduced - a boolean flag that can be set to indicate that the reducing process should stop, even though there is still input to process

Returns:

the final reduced result