Uses of Interface
java.util.stream.Gatherer.Integrator
Package
Description
Classes to support functional-style operations on streams of elements, such
as map-reduce transformations on collections.
-
Uses of Gatherer.Integrator in java.util.stream
Modifier and TypeInterfaceDescriptionstatic interface
Gatherer.Integrator.Greedy<A,
T, R> Greedy Integrators consume all their input, and may only relay that the downstream does not want more elements.Modifier and TypeMethodDescriptionGatherer.integrator()
A function which integrates provided elements, potentially using the provided intermediate state, optionally producing output to the providedGatherer.Downstream
.static <A,
T, R> Gatherer.Integrator <A, T, R> Gatherer.Integrator.of
(Gatherer.Integrator<A, T, R> integrator) Factory method for turning Integrator-shaped lambdas into Integrators.Modifier and TypeMethodDescriptionstatic <A,
T, R> Gatherer.Integrator <A, T, R> Gatherer.Integrator.of
(Gatherer.Integrator<A, T, R> integrator) Factory method for turning Integrator-shaped lambdas into Integrators.static <T,
A, R> Gatherer <T, A, R> Gatherer.of
(Supplier<A> initializer, Gatherer.Integrator<A, T, R> integrator, BinaryOperator<A> combiner, BiConsumer<A, Gatherer.Downstream<? super R>> finisher) Returns a new, parallelizable,Gatherer
described by the giveninitializer
,integrator
,combiner
andfinisher
.Gatherer.of
(Gatherer.Integrator<Void, T, R> integrator) Returns a new, parallelizable, and statelessGatherer
described by the givenintegrator
.Gatherer.of
(Gatherer.Integrator<Void, T, R> integrator, BiConsumer<Void, Gatherer.Downstream<? super R>> finisher) Returns a new, parallelizable, and statelessGatherer
described by the givenintegrator
andfinisher
.static <T,
A, R> Gatherer <T, A, R> Gatherer.ofSequential
(Supplier<A> initializer, Gatherer.Integrator<A, T, R> integrator) Returns a new, sequential,Gatherer
described by the giveninitializer
andintegrator
.static <T,
A, R> Gatherer <T, A, R> Gatherer.ofSequential
(Supplier<A> initializer, Gatherer.Integrator<A, T, R> integrator, BiConsumer<A, Gatherer.Downstream<? super R>> finisher) Returns a new, sequential,Gatherer
described by the giveninitializer
,integrator
, andfinisher
.Gatherer.ofSequential
(Gatherer.Integrator<Void, T, R> integrator) Returns a new, sequential, and statelessGatherer
described by the givenintegrator
.Gatherer.ofSequential
(Gatherer.Integrator<Void, T, R> integrator, BiConsumer<Void, Gatherer.Downstream<? super R>> finisher) Returns a new, sequential, and statelessGatherer
described by the givenintegrator
andfinisher
.