-
Notifications
You must be signed in to change notification settings - Fork 6
Closed
Milestone
Description
When the partials are bigger than the step size, one might expect the window to continue stepping, see #134.
E.g.:
final Stream<String> input = Stream.of("A", "B", "C", "D", "E", "F", "G");
input.gather(Gatherers4j.window(5, 2, true)).forEach(System.out::println);
Output might be expected to be:
[A, B, C, D, E]
[C, D, E, F, G]
[E, F, G]
[G]
Currently, last line is omitted. Of course, you can define window to have whatever behavior you like.
Metadata
Metadata
Assignees
Labels
No labels