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

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

@@ -280,15 +280,16 @@
                         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
-                        LongStream result = mapper.apply(t);
                         if (result != null)
                             result.sequential().forEach(i -> downstream.accept(i));
                     }
+                    }
                 };
             }
         };
     }