Skip to content

Commit

Permalink
Make Collectors2.sumBy tests consistent for groupBy keys.
Browse files Browse the repository at this point in the history 
Signed-off-by: Donald Raab <Donald.Raab@gs.com>
  • Loading branch information
Donald Raab authored and Donald Raab committed Jan 7, 2017
1 parent 4dc2f81 commit 05a6865
Showing 1 changed file with 25 additions and 25 deletions.
50 changes: 25 additions & 25 deletions ...tests/src/test/java/org/eclipse/collections/impl/collector/Collectors2AdditionalTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@
public class Collectors2AdditionalTest
{
public static final Interval SMALL_INTERVAL = Interval.oneTo(5);
public static final Interval LARGE_INTERVAL = Interval.oneTo(20000);
public static final Interval LARGE_INTERVAL = Interval.oneTo(200000);
public static final Integer HALF_SIZE = Integer.valueOf(LARGE_INTERVAL.size() / 2);
private final List<Integer> smallData = new ArrayList<Integer>(SMALL_INTERVAL);
private final List<Integer> bigData = new ArrayList<Integer>(LARGE_INTERVAL);
Expand Down Expand Up @@ -144,20 +144,20 @@ public void zipWithIndexParallel()
public void sumByInt()
{
Assert.assertEquals(
SMALL_INTERVAL.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue),
SMALL_INTERVAL.stream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue)));
SMALL_INTERVAL.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue),
SMALL_INTERVAL.stream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue)));

Assert.assertEquals(
LARGE_INTERVAL.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue),
LARGE_INTERVAL.stream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue)));
LARGE_INTERVAL.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue),
LARGE_INTERVAL.stream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue)));
}

@Test
public void sumByIntParallel()
{
Assert.assertEquals(
LARGE_INTERVAL.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue),
LARGE_INTERVAL.parallelStream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each % 2), Integer::intValue)));
LARGE_INTERVAL.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue),
LARGE_INTERVAL.parallelStream().collect(Collectors2.sumByInt(each -> Integer.valueOf(each.intValue() % 2), Integer::intValue)));
}

@Test
Expand All @@ -166,21 +166,21 @@ public void sumByLong()
MutableList<Long> smallLongs = SMALL_INTERVAL.collect(Long::valueOf).toList();
MutableList<Long> largeLongs = LARGE_INTERVAL.collect(Long::valueOf).toList();
Assert.assertEquals(
smallLongs.sumByLong(each -> Long.valueOf(each % 2), Long::longValue),
smallLongs.stream().collect(Collectors2.sumByLong(each -> Long.valueOf(each % 2), Long::longValue)));
smallLongs.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue),
smallLongs.stream().collect(Collectors2.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue)));

Assert.assertEquals(
largeLongs.sumByLong(each -> Long.valueOf(each % 2), Long::longValue),
largeLongs.stream().collect(Collectors2.sumByLong(each -> Long.valueOf(each % 2), Long::longValue)));
largeLongs.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue),
largeLongs.stream().collect(Collectors2.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue)));
}

@Test
public void sumByLongParallel()
{
MutableList<Long> largeLongs = LARGE_INTERVAL.collect(Long::valueOf).toList();
Assert.assertEquals(
largeLongs.sumByLong(each -> Long.valueOf(each % 2), Long::longValue),
largeLongs.parallelStream().collect(Collectors2.sumByLong(each -> Long.valueOf(each % 2), Long::longValue)));
largeLongs.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue),
largeLongs.parallelStream().collect(Collectors2.sumByLong(each -> Integer.valueOf(each.intValue() % 2), Long::longValue)));
}

@Test
Expand All @@ -189,21 +189,21 @@ public void sumByFloat()
MutableList<Float> smallLongs = SMALL_INTERVAL.collect(Float::valueOf).toList();
MutableList<Float> largeLongs = LARGE_INTERVAL.collect(Float::valueOf).toList();
Assert.assertEquals(
smallLongs.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue),
smallLongs.stream().collect(Collectors2.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue)));
smallLongs.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue),
smallLongs.stream().collect(Collectors2.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue)));

Assert.assertEquals(
largeLongs.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue),
largeLongs.stream().collect(Collectors2.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue)));
largeLongs.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue),
largeLongs.stream().collect(Collectors2.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue)));
}

@Test
public void sumByFloatParallel()
{
MutableList<Float> largeLongs = LARGE_INTERVAL.collect(Float::valueOf).toList();
Assert.assertEquals(
largeLongs.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue),
largeLongs.parallelStream().collect(Collectors2.sumByFloat(each -> Float.valueOf(each % 2), Float::floatValue)));
largeLongs.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue),
largeLongs.parallelStream().collect(Collectors2.sumByFloat(each -> Integer.valueOf(each.intValue() % 2), Float::floatValue)));
}

@Test
Expand All @@ -212,21 +212,21 @@ public void sumByDouble()
MutableList<Double> smallLongs = SMALL_INTERVAL.collect(Double::valueOf).toList();
MutableList<Double> largeLongs = LARGE_INTERVAL.collect(Double::valueOf).toList();
Assert.assertEquals(
smallLongs.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue),
smallLongs.stream().collect(Collectors2.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue)));
smallLongs.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue),
smallLongs.stream().collect(Collectors2.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue)));

Assert.assertEquals(
largeLongs.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue),
largeLongs.stream().collect(Collectors2.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue)));
largeLongs.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue),
largeLongs.stream().collect(Collectors2.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue)));
}

@Test
public void sumByDoubleParallel()
{
MutableList<Double> largeLongs = LARGE_INTERVAL.collect(Double::valueOf).toList();
Assert.assertEquals(
largeLongs.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue),
largeLongs.parallelStream().collect(Collectors2.sumByDouble(each -> Double.valueOf(each % 2), Double::doubleValue)));
largeLongs.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue),
largeLongs.parallelStream().collect(Collectors2.sumByDouble(each -> Integer.valueOf(each.intValue() % 2), Double::doubleValue)));
}

@Test
Expand Down

0 comments on commit 05a6865

Please sign in to comment.