将流分成具有N个元素的子流

Question

在Java中，我们能否以某种方式将流分成不超过N个元素的子流？例如

Stream<Integer> s = Stream.of(1,2,3,4,5);
Stream<Stream<Integer>> separated = split(s, 2);
// after that separated should contain stream(1,2), stream(3,4), stream(5)

按两个流拆分的解决方案仅对2个流是正确的，对于N个流也是如此，这将是非常丑陋和只写的。

Answer 1

例如：

<T> Stream<Stream<T>> split(Stream<T> stream, int n) {
  final var it = stream.iterator();
  final Stream.Builder<Stream<T>> result = Stream.builder();
  while (it.hasNext()) {
    final Stream.Builder<T> buf = Stream.builder();
    for (int i = 0; i < n && it.hasNext(); i++) {
      buf.accept(it.next());
    }
    result.accept(buf.build());
  }
  return result.build();
}


Stream<Integer> s = Stream.of(1,2,3,4,5);
Stream<Stream<Integer>> separated = split(s, 2);
separated.map(x -> x.collect(Collectors.toList())).forEach(System.out::println);

[1, 2]
[3, 4]
[5]

Answer 2

您无法轻松直接地将流拆分为2个或更多列。唯一的方法是程序性的方法，包括由夫妇将元素收集到列表，然后将它们再次映射回流：

Stream<Integer> s = Stream.of(1,2,3,4,5);
List<Integer> list = s.collect(Collectors.toList());
int size = list.size();
    
List<List<Integer>> temp = new ArrayList<>();
List<Integer> temp2 = new ArrayList<>();
    
int index = 0;
for (int i=0; i<size; i++) {
    temp2.add(list.get(i));
    if (i%2!=0) {
        temp.add(temp2);
        temp2 = new ArrayList<>();
    }
    if (i == size - 1) {
        temp.add(temp2);
    }
}
Stream<Stream<Integer>> stream = temp.stream().map(i -> i.stream());

如你所见，这是一条很长的路，不值得。将配对存储在< code>List而不是< code>Stream中不是更好吗？java-stream API不是用于数据存储，而是用于数据处理。