Cross Reference: /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/LongStreamTestScenario.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, LongConsumer b, Function<S_IN, LongStream> m) {
49             LongStream s = m.apply(data.stream());
60         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
61             for (long t : m.apply(data.stream()).toArray()) {
69         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
70             for (PrimitiveIterator.OfLong seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
78         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
79             for (Spliterator.OfLong spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
87         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
88             SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
95         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
96             m.apply(data.stream()).spliterator().forEachRemaining(b);
102         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
103             m.apply(data.parallelStream()).sequential().forEach(b);
110         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
112             m.apply(data.parallelStream()).forEachOrdered(b);
119         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
120             for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
128         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
129             m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
135         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
136             for (long t : m.apply(data.parallelStream()).toArray())
144         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
145             LongStream s = m.apply(data.parallelStream());
157         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
158             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
159                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
170         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
171             m.apply(data.parallelStream()).forEach(e -> {
172                 synchronized (data) {
182         void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) {
183             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
184                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
186                 synchronized (data) {
224     void run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, S_OUT> m) {
225         _run(data, (LongConsumer) b, (Function<S_IN, LongStream>) m);
229     void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m);