30 import java.util.LinkedHashSet;
31 import java.util.List;
32 import java.util.Map;
33 import java.util.Set;
34 import java.util.concurrent.atomic.AtomicBoolean;
35 import java.util.function.Function;
36 import java.util.function.Predicate;
37 import java.util.stream.DefaultMethodStreams;
38 import java.util.stream.DoubleStream;
39 import java.util.stream.IntStream;
40 import java.util.stream.LambdaTestHelpers;
41 import java.util.stream.LongStream;
42 import java.util.stream.OpTestCase;
43 import java.util.stream.Stream;
44 import java.util.stream.StreamTestDataProvider;
45 import java.util.stream.TestData;
46
47 /*
48 * @test
49 * @bug 8071597 8193856
50 */
51 @Test
52 public class WhileOpTest extends OpTestCase {
53
54 @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
55 groups = { "serialization-hostile" })
56 public void testTakeWhileOps(String name, TestData.OfRef<Integer> data) {
57 for (int size : sizes(data.size())) {
58 setContext("takeWhile", size);
59
60 testWhileMulti(data,
61 whileResultAsserter(data, WhileOp.Take, e -> e < size),
62 s -> s.takeWhile(e -> e < size),
63 s -> s.takeWhile(e -> e < size),
64 s -> s.takeWhile(e -> e < size),
65 s -> s.takeWhile(e -> e < size));
66
67
68 testWhileMulti(data,
69 whileResultAsserter(data, WhileOp.Take, e -> e < size / 2),
|
30 import java.util.LinkedHashSet;
31 import java.util.List;
32 import java.util.Map;
33 import java.util.Set;
34 import java.util.concurrent.atomic.AtomicBoolean;
35 import java.util.function.Function;
36 import java.util.function.Predicate;
37 import java.util.stream.DefaultMethodStreams;
38 import java.util.stream.DoubleStream;
39 import java.util.stream.IntStream;
40 import java.util.stream.LambdaTestHelpers;
41 import java.util.stream.LongStream;
42 import java.util.stream.OpTestCase;
43 import java.util.stream.Stream;
44 import java.util.stream.StreamTestDataProvider;
45 import java.util.stream.TestData;
46
47 /*
48 * @test
49 * @bug 8071597 8193856
50 * @run main/timeout=240
51 */
52 @Test
53 public class WhileOpTest extends OpTestCase {
54
55 @Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class,
56 groups = { "serialization-hostile" })
57 public void testTakeWhileOps(String name, TestData.OfRef<Integer> data) {
58 for (int size : sizes(data.size())) {
59 setContext("takeWhile", size);
60
61 testWhileMulti(data,
62 whileResultAsserter(data, WhileOp.Take, e -> e < size),
63 s -> s.takeWhile(e -> e < size),
64 s -> s.takeWhile(e -> e < size),
65 s -> s.takeWhile(e -> e < size),
66 s -> s.takeWhile(e -> e < size));
67
68
69 testWhileMulti(data,
70 whileResultAsserter(data, WhileOp.Take, e -> e < size / 2),
|