Cross Reference: /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/DoubleStreamTestScenario.java

Lines Matching refs:data
41  * Each scenario is provided with a data source, a function that maps a fresh
42  * stream (as provided by the data source) to a new stream, and a sink to
52         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
53             DoubleStream s = m.apply(data.stream());
64         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
65             for (double t : m.apply(data.stream()).toArray()) {
73         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
74             for (PrimitiveIterator.OfDouble seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
82         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
83             for (Spliterator.OfDouble spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
91         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
92             SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
99         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
100             m.apply(data.stream()).spliterator().forEachRemaining(b);
106         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
107             m.apply(data.parallelStream()).sequential().forEach(b);
114         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
116             m.apply(data.parallelStream()).forEachOrdered(b);
123         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
124             for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
132         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
133             m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
139         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
140             for (double t : m.apply(data.parallelStream()).toArray())
148         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
149             DoubleStream s = m.apply(data.parallelStream());
161         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
162             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
163                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
174         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
175             m.apply(data.parallelStream()).forEach(e -> {
176                 synchronized (data) {
186         void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m) {
187             S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
188                                                  new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape()));
190                 synchronized (data) {
228     void run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, S_OUT> m) {
229         _run(data, (DoubleConsumer) b, (Function<S_IN, DoubleStream>) m);
233     void _run(TestData<T, S_IN> data, DoubleConsumer b, Function<S_IN, DoubleStream> m);