java - 有条件地对流应用限制 - "stream has already been operated upon or closed"

Question

我需要在流上有条件地应用limit(Integer)操作。我的第一个方法是(试图避免终端操作):

Stream<CustomerDetailsEntity> resultStream = aList
        // filter ...
        .stream().filter(c -> distinctPartnerNumber.add(c.getPartnerNumber()));
if (limit != null) {
    resultStream.limit(limit);
}
return resultStream.collect(toList());

如果应用限制，这将产生流已被操作或关闭。 limit 是“终端操作”吗？

谷歌搜索流已被操作或关闭建议使用供应商，但这样我就无法重用供应商:

Supplier<Stream<CustomerDetailsEntity>> resultStreamSup =()-> aList
        // filter ...
        .stream().filter(c -> distinctPartnerNumber.add(c.getPartnerNumber()));
if (limit != null) {
    resultStreamSup = () -> resultStreamSup.get.limit(limit); //COMPILE ERROR, due to supplier is not final
}

...

那么如何有条件地正确应用限制(我想像往常一样避免多个返回语句)？

Answer 1

您忽略了 limit() 的返回值。

它应该是resultStream = resultStream.limit(limit);，因为原始流不会被调用修改。

Returns a stream consisting of the elements of this stream, truncated to be no longer than {@code maxSize} in length.