infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-05-20 18:37:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

8075230: Optimized count operations incorrectly declare the stream shape

Browse Source 
Reviewed-by: chegar
This commit is contained in:
Paul Sandoz 2015-03-16 17:44:34 +01:00
parent 765a1e4435
commit 7618752fd9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jdk/src/java.base/share/classes/java/util/stream/ReduceOps.java
View File

@ -414,7 +414,7 @@ final class ReduceOps {
*/
public static TerminalOp<Integer, Long>
makeIntCounting() {
return new ReduceOp<Integer, Long, CountingSink<Integer>>(StreamShape.REFERENCE) {
return new ReduceOp<Integer, Long, CountingSink<Integer>>(StreamShape.INT_VALUE) {
@Override
public CountingSink<Integer> makeSink() { return new CountingSink.OfInt(); }
@ -583,7 +583,7 @@ final class ReduceOps {
*/
public static TerminalOp<Long, Long>
makeLongCounting() {
return new ReduceOp<Long, Long, CountingSink<Long>>(StreamShape.REFERENCE) {
return new ReduceOp<Long, Long, CountingSink<Long>>(StreamShape.LONG_VALUE) {
@Override
public CountingSink<Long> makeSink() { return new CountingSink.OfLong(); }
@ -752,7 +752,7 @@ final class ReduceOps {
*/
public static TerminalOp<Double, Long>
makeDoubleCounting() {
return new ReduceOp<Double, Long, CountingSink<Double>>(StreamShape.REFERENCE) {
return new ReduceOp<Double, Long, CountingSink<Double>>(StreamShape.DOUBLE_VALUE) {
@Override
public CountingSink<Double> makeSink() { return new CountingSink.OfDouble(); }