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

rev 7982 : 8017513: Support for closeable streams
8022237: j.u.s.BaseStream.onClose() has an issue in implementation or requires spec clarification
8022572: Same exception instances thrown from j.u.stream.Stream.onClose() handlers are not listed as suppressed
Summary: BaseStream implements AutoCloseable; Remove CloseableStream and DelegatingStream
Reviewed-by: alanb, mduigou, psandoz
Contributed-by: brian.goetz@oracle.com

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