src/share/classes/java/util/stream/LongPipeline.java

Print this page
rev 7633 : 8017513: Support for closeable streams
Reviewed-by:
Contributed-by: brian.goetz@oracle.com

*** 280,294 **** downstream.begin(-1); } @Override public void accept(long t) { // We can do better that this too; optimize for depth=0 case and just grab spliterator and forEach it - LongStream result = mapper.apply(t); if (result != null) result.sequential().forEach(i -> downstream.accept(i)); } }; } }; } --- 280,295 ---- downstream.begin(-1); } @Override public void accept(long t) { + try (LongStream result = mapper.apply(t)) { // We can do better that this too; optimize for depth=0 case and just grab spliterator and forEach it if (result != null) result.sequential().forEach(i -> downstream.accept(i)); } + } }; } }; }