提交 f5c43a90 编写于 作者: P psandoz

8025567: Mark relevant public stream tests as serialization hostile

Reviewed-by: alanb
上级 a80e13e1
...@@ -69,7 +69,7 @@ public class ForEachOpTest extends OpTestCase { ...@@ -69,7 +69,7 @@ public class ForEachOpTest extends OpTestCase {
}; };
} }
@Test @Test(groups = { "serialization-hostile" })
public void testForEachOrdered() { public void testForEachOrdered() {
List<Integer> input = countTo(10000); List<Integer> input = countTo(10000);
TestData.OfRef<Integer> data = TestData.Factory.ofCollection("[1, 10000]", input); TestData.OfRef<Integer> data = TestData.Factory.ofCollection("[1, 10000]", input);
...@@ -116,7 +116,7 @@ public class ForEachOpTest extends OpTestCase { ...@@ -116,7 +116,7 @@ public class ForEachOpTest extends OpTestCase {
// //
@Test @Test(groups = { "serialization-hostile" })
public void testIntForEachOrdered() { public void testIntForEachOrdered() {
List<Integer> input = countTo(10000); List<Integer> input = countTo(10000);
TestData.OfInt data = TestData.Factory.ofIntSupplier("[1, 10000]", TestData.OfInt data = TestData.Factory.ofIntSupplier("[1, 10000]",
...@@ -164,7 +164,7 @@ public class ForEachOpTest extends OpTestCase { ...@@ -164,7 +164,7 @@ public class ForEachOpTest extends OpTestCase {
// //
@Test @Test(groups = { "serialization-hostile" })
public void testLongForEachOrdered() { public void testLongForEachOrdered() {
List<Integer> input = countTo(10000); List<Integer> input = countTo(10000);
TestData.OfLong data = TestData.Factory.ofLongSupplier("[1, 10000]", TestData.OfLong data = TestData.Factory.ofLongSupplier("[1, 10000]",
...@@ -212,7 +212,7 @@ public class ForEachOpTest extends OpTestCase { ...@@ -212,7 +212,7 @@ public class ForEachOpTest extends OpTestCase {
// //
@Test @Test(groups = { "serialization-hostile" })
public void testDoubleForEachOrdered() { public void testDoubleForEachOrdered() {
List<Integer> input = countTo(10000); List<Integer> input = countTo(10000);
TestData.OfDouble data = TestData.Factory.ofDoubleSupplier("[1, 10000]", TestData.OfDouble data = TestData.Factory.ofDoubleSupplier("[1, 10000]",
......
...@@ -147,7 +147,8 @@ public class SliceOpTest extends OpTestCase { ...@@ -147,7 +147,8 @@ public class SliceOpTest extends OpTestCase {
return Math.max(0, dataSize - skip); return Math.max(0, dataSize - skip);
} }
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class) @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
groups = { "serialization-hostile" })
public void testSkipOps(String name, TestData.OfRef<Integer> data) { public void testSkipOps(String name, TestData.OfRef<Integer> data) {
List<Integer> skips = sizes(data.size()); List<Integer> skips = sizes(data.size());
...@@ -169,7 +170,8 @@ public class SliceOpTest extends OpTestCase { ...@@ -169,7 +170,8 @@ public class SliceOpTest extends OpTestCase {
} }
} }
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class) @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
groups = { "serialization-hostile" })
public void testSkipLimitOps(String name, TestData.OfRef<Integer> data) { public void testSkipLimitOps(String name, TestData.OfRef<Integer> data) {
List<Integer> skips = sizes(data.size()); List<Integer> skips = sizes(data.size());
List<Integer> limits = skips; List<Integer> limits = skips;
...@@ -242,7 +244,8 @@ public class SliceOpTest extends OpTestCase { ...@@ -242,7 +244,8 @@ public class SliceOpTest extends OpTestCase {
testSkipLimitOps("testSkipLimitOpsWithNonSplittingSpliterator", data); testSkipLimitOps("testSkipLimitOpsWithNonSplittingSpliterator", data);
} }
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class) @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
groups = { "serialization-hostile" })
public void testLimitOps(String name, TestData.OfRef<Integer> data) { public void testLimitOps(String name, TestData.OfRef<Integer> data) {
List<Integer> limits = sizes(data.size()); List<Integer> limits = sizes(data.size());
......
...@@ -97,7 +97,7 @@ public class StreamBuilderTest extends OpTestCase { ...@@ -97,7 +97,7 @@ public class StreamBuilderTest extends OpTestCase {
checkISE(() -> sb.build()); checkISE(() -> sb.build());
} }
@Test(dataProvider = "sizes") @Test(dataProvider = "sizes", groups = { "serialization-hostile" })
public void testStreamBuilder(int size) { public void testStreamBuilder(int size) {
testStreamBuilder(size, (s) -> { testStreamBuilder(size, (s) -> {
Stream.Builder<Integer> sb = Stream.builder(); Stream.Builder<Integer> sb = Stream.builder();
...@@ -159,7 +159,7 @@ public class StreamBuilderTest extends OpTestCase { ...@@ -159,7 +159,7 @@ public class StreamBuilderTest extends OpTestCase {
checkISE(() -> sb.build()); checkISE(() -> sb.build());
} }
@Test(dataProvider = "sizes") @Test(dataProvider = "sizes", groups = { "serialization-hostile" })
public void testIntStreamBuilder(int size) { public void testIntStreamBuilder(int size) {
testIntStreamBuilder(size, (s) -> { testIntStreamBuilder(size, (s) -> {
IntStream.Builder sb = IntStream.builder(); IntStream.Builder sb = IntStream.builder();
...@@ -221,7 +221,7 @@ public class StreamBuilderTest extends OpTestCase { ...@@ -221,7 +221,7 @@ public class StreamBuilderTest extends OpTestCase {
checkISE(() -> sb.build()); checkISE(() -> sb.build());
} }
@Test(dataProvider = "sizes") @Test(dataProvider = "sizes", groups = { "serialization-hostile" })
public void testLongStreamBuilder(int size) { public void testLongStreamBuilder(int size) {
testLongStreamBuilder(size, (s) -> { testLongStreamBuilder(size, (s) -> {
LongStream.Builder sb = LongStream.builder(); LongStream.Builder sb = LongStream.builder();
...@@ -282,7 +282,7 @@ public class StreamBuilderTest extends OpTestCase { ...@@ -282,7 +282,7 @@ public class StreamBuilderTest extends OpTestCase {
checkISE(() -> sb.build()); checkISE(() -> sb.build());
} }
@Test(dataProvider = "sizes") @Test(dataProvider = "sizes", groups = { "serialization-hostile" })
public void testDoubleStreamBuilder(int size) { public void testDoubleStreamBuilder(int size) {
testDoubleStreamBuilder(size, (s) -> { testDoubleStreamBuilder(size, (s) -> {
DoubleStream.Builder sb = DoubleStream.builder(); DoubleStream.Builder sb = DoubleStream.builder();
......
...@@ -165,7 +165,8 @@ public class ToArrayOpTest extends OpTestCase { ...@@ -165,7 +165,8 @@ public class ToArrayOpTest extends OpTestCase {
}; };
} }
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class) @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
groups = { "serialization-hostile" })
public void testStatefulOpPermutations(String name, TestData.OfRef<Integer> data) { public void testStatefulOpPermutations(String name, TestData.OfRef<Integer> data) {
for (Function<Stream<Integer>, Stream<Integer>> f : statefulOpPermutations) { for (Function<Stream<Integer>, Stream<Integer>> f : statefulOpPermutations) {
withData(data).terminal(f, s -> s.toArray()) withData(data).terminal(f, s -> s.toArray())
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册