--- old/test/java/util/stream/test/org/openjdk/tests/java/util/stream/StreamCloseTest.java	2016-01-23 15:13:23.100121200 +0600
+++ new/test/java/util/stream/test/org/openjdk/tests/java/util/stream/StreamCloseTest.java	2016-01-23 15:13:22.910597100 +0600
@@ -37,6 +37,7 @@
 
 import static java.util.stream.LambdaTestHelpers.countTo;
 import static java.util.stream.ThowableHelper.checkNPE;
+import static java.util.stream.ThowableHelper.checkISE;
 
 @Test(groups = { "serialization-hostile" })
 public class StreamCloseTest extends OpTestCase {
@@ -170,4 +171,21 @@
         for (int i=0; i<n-1; i++)
         assertTrue(e.getSuppressed()[i].getMessage().equals(String.valueOf(i + 2)));
     }
+
+    public void testConsumed() {
+        try(Stream<Integer> s = countTo(100).stream()) {
+            s.forEach(i -> {});
+            checkISE(() -> s.onClose(() -> fail("1")));
+        }
+
+        try(Stream<Integer> s = countTo(100).stream()) {
+            s.map(x -> x).forEach(i -> {});
+            checkISE(() -> s.onClose(() -> fail("2")));
+        }
+
+        try(Stream<Integer> s = countTo(100).stream()) {
+            s.close();
+            checkISE(() -> s.onClose(() -> fail("3")));
+        }
+    }
 }