Doesn't

reduce

reduce N items into a single output? Should I create a collector that collects the N items into a list of newItems of length M then flatMap afterwards to get a stream of newItems?