Cross Reference: /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/IntStreamTestScenario.java

Lines Matching refs:data
37  * Each scenario is provided with a data source, a function that maps a fresh
38  * stream (as provided by the data source) to a new stream, and a sink to
48         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
49             IntStream s = m.apply(data.stream());
60         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
61             for (int t : m.apply(data.stream()).toArray()) {
69         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
70             for (PrimitiveIterator.OfInt seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
78         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
79             for (Spliterator.OfInt spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
87         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
88             SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
95         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
96             m.apply(data.stream()).spliterator().forEachRemaining(b);
102         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
103             m.apply(data.parallelStream()).sequential().forEach(b);
110         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
112             m.apply(data.parallelStream()).forEachOrdered(b);
119         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
120             for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
128         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
129             m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
135         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
136             for (int t : m.apply(data.parallelStream()).toArray())
144         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
145             IntStream s = m.apply(data.parallelStream());
158         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
159             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
160                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
171         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
172             m.apply(data.parallelStream()).forEach(e -> {
173                 synchronized (data) {
183         void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m) {
184             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
185                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
187                 synchronized (data) {
225     void run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, S_OUT> m) {
226         _run(data, (IntConsumer) b, (Function<S_IN, IntStream>) m);
230     void _run(TestData<T, S_IN> data, IntConsumer b, Function<S_IN, IntStream> m);