< prev index next >
test/java/util/stream/test/org/openjdk/tests/java/util/stream/SliceOpTest.java
Print this page
@@ -339,6 +339,15 @@
}
else {
return Arrays.asList(0, 1, size / 2, size - 1, size, size + 1, 2 * size);
}
}
+
+ public void testLimitParallelHugeInput() {
+ for (int n : new int[] {10, 100, 1000, 10000}) {
+ long[] actual = LongStream.range(0, Long.MAX_VALUE)
+ .parallel().filter(x -> true) // remove SIZED
+ .limit(n).toArray();
+ assertEquals(LongStream.range(0, n).toArray(), actual);
+ }
+ }
}
< prev index next >