我可以将一条流拆分为多条较小的流吗

Question

除了这个用例，流还有很多问题

我有一个巨大的对象流Stream

Class A { enum status [Running,queued,Completed], String name }

我想拆分流

在调用stream时，我面临StackOverflowException。我在这里重复了好几次。

Stream. Concat在JavaDocs"实现说明：从重复连接构造流时要小心。访问深度连接流的元素可能会导致深度调用链，甚至StackOverflow Exception。"

Map<Status, Stream<String>> splitStream = new HashMap<>();
streamA.foreach(aObj -> 
Stream<String> statusBasedStream = splitStream.getOrDefault(aObj.status,Stream.of());
splitStream.put(aObj.status, Stream.concat(statusBasedStream, Stream.of(aObj.name))); 

在github中，可以使用定制流来实现连接的选项很少，但希望使用标准库来解决这个问题。

如果数据较小，则应采用此处所述的列表方法（将流拆分为包含N个元素的子流）




Answer 1

这不是问题的精确解决方案，但如果你有关于索引的信息，那么组合流。跳过（）和流。limit（）可以帮上忙——下面是我尝试过的伪代码-

    int queuedNumbers = 100;
    int runningNumbers=200;
    Stream<Object> all = Stream.of();
    Stream<Object> queuedAndCompleted = all.skip(queuedNumbers);
    Stream<Object> queued = all.limit(queuedNumbers);
    Stream<Object> running = queuedAndCompleted.limit(runningNumbers);
    Stream<Object> completed = queuedAndCompleted.skip(runningNumbers);

希望能有所帮助。