Hi, I did some testing where one gatherer (doNothingReturnTrue) does not handle the downStream.push(element) returning false correctly. The stream processing is terminated in one case and not in the two other.Especially see the difference between output from handling «efgh» and «EFGH» below. Is th
nterface Integrator {
.
static NonGreedy of(NonGreedy integrator) {
return integrator;
}
static Greedy ofGreedy(Greedy greedy) {
return greedy;
}
interface Greedy extends Integrator { }
interface NonGreedy extends Integrator { }
Tested the Gatherer implementation, and it is a very nice work.
I have always wanted a way of writing my own stream operations and also have
incomplete composable pipelines which could be combined in different ways. Very
interesting.
The four Gatherer functions - initializer/integrator/combiner
