com.github.robtimus.stream

Class StreamUtils

java.lang.Object

com.github.robtimus.stream.StreamUtils

public final class StreamUtils
extends Object

A utility class for streams.

Author:

Rob Spoor

Method Summary

Modifier and Type	Method and Description
static <T,R> void	forEvery(int count, Stream<T> stream, Collector<? super T,?,R> collector, Consumer<? super R> action) Reduces elements of a stream in partitions of a specific size, then runs an action for each reduction result.

Methods inherited from class java.lang.Object

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

Method Detail

forEvery

public static <T,R> void forEvery(int count,
                                  Stream<T> stream,
                                  Collector<? super T,?,R> collector,
                                  Consumer<? super R> action)

Reduces elements of a stream in partitions of a specific size, then runs an action for each reduction result. This method can be described as "for every count elements of stream, collect using collector, then run action on the collector's result".

Note: this method does not support concurrent streams.

Type Parameters:

T - The type of stream elements.

R - The type of result of reducing each partition.

Parameters:

count - The number of elements in each partition.

stream - The Stream to reduce elements for.

collector - The Collector to use for reducing partitions.

action - The action to run for each reduction result.