Home
last modified time | relevance | path

Searched refs:StreamShape (Results 1 – 25 of 40) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DCollectorOps.java35 return new StatefulCollector<>(0, StreamShape.REFERENCE); in collector()
41 private final StreamShape inputShape;
43 public StatefulCollector(int opFlags, StreamShape inputShape) { in StatefulCollector()
49 public StreamShape inputShape() { in inputShape()
54 public StreamShape outputShape() { in outputShape()
78 this(StreamShape.REFERENCE); in TestParallelSizedOp()
81 protected TestParallelSizedOp(StreamShape shape) { in TestParallelSizedOp()
97 super(StreamShape.INT_VALUE); in OfInt()
103 super(StreamShape.LONG_VALUE); in OfLong()
109 super(StreamShape.DOUBLE_VALUE); in OfDouble()
DFlagDeclaringOp.java31 private final StreamShape shape;
34 this(flags, StreamShape.REFERENCE); in FlagDeclaringOp()
37 public FlagDeclaringOp(int flags, StreamShape shape) { in FlagDeclaringOp()
43 public StreamShape outputShape() { in outputShape()
48 public StreamShape inputShape() { in inputShape()
DTestFlagExpectedOp.java33 StreamShape shape = StreamShape.REFERENCE;
58 Builder<T> shape(StreamShape shape) { in shape()
71 final StreamShape shape;
77 this(flags, known, preserve, notKnown, StreamShape.REFERENCE); in TestFlagExpectedOp()
84 StreamShape shape) { in TestFlagExpectedOp()
93 public StreamShape outputShape() { in outputShape()
98 public StreamShape inputShape() { in inputShape()
DStatelessTestOp.java65 default StreamShape inputShape() { return StreamShape.REFERENCE; }
67 default StreamShape outputShape() { return StreamShape.REFERENCE; }
DOpTestCase.java54 private final Map<StreamShape, Set<? extends BaseStreamTestScenario>> testScenarios;
57 testScenarios = new EnumMap<>(StreamShape.class); in OpTestCase()
58 …testScenarios.put(StreamShape.REFERENCE, Collections.unmodifiableSet(EnumSet.allOf(StreamTestScena… in OpTestCase()
59 …testScenarios.put(StreamShape.INT_VALUE, Collections.unmodifiableSet(EnumSet.allOf(IntStreamTestSc… in OpTestCase()
60 …testScenarios.put(StreamShape.LONG_VALUE, Collections.unmodifiableSet(EnumSet.allOf(LongStreamTest… in OpTestCase()
61 …testScenarios.put(StreamShape.DOUBLE_VALUE, Collections.unmodifiableSet(EnumSet.allOf(DoubleStream… in OpTestCase()
91 StreamShape getShape(); in getShape()
251 final StreamShape shape;
449 default R run(Function<S_OUT, R> terminalF, S_OUT source, StreamShape shape) { in run()
460 public Object run(Function terminalF, BaseStream source, StreamShape shape) { in SINGLE_SEQUENTIAL_SHORT_CIRCUIT()
[all …]
DStatefulTestOp.java121 default StreamShape inputShape() { return StreamShape.REFERENCE; }
123 default StreamShape outputShape() { return StreamShape.REFERENCE; }
DTestData.java57 StreamShape getShape(); in getShape()
212 private final StreamShape shape;
220 StreamShape shape, in AbstractTestData()
236 public StreamShape getShape() { in getShape()
275 super(name, StreamShape.REFERENCE, state, streamFn, parStreamFn, splitrFn, sizeFn); in RefTestData()
290 super(name, StreamShape.INT_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in IntTestData()
315 super(name, StreamShape.LONG_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in LongTestData()
340 … super(name, StreamShape.DOUBLE_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in DoubleTestData()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DCollectorOps.java36 return new StatefulCollector<>(0, StreamShape.REFERENCE); in collector()
42 private final StreamShape inputShape;
44 public StatefulCollector(int opFlags, StreamShape inputShape) { in StatefulCollector()
50 public StreamShape inputShape() { in inputShape()
55 public StreamShape outputShape() { in outputShape()
79 this(StreamShape.REFERENCE); in TestParallelSizedOp()
82 protected TestParallelSizedOp(StreamShape shape) { in TestParallelSizedOp()
98 super(StreamShape.INT_VALUE); in OfInt()
104 super(StreamShape.LONG_VALUE); in OfLong()
110 super(StreamShape.DOUBLE_VALUE); in OfDouble()
DFlagDeclaringOp.java26 import java.util.stream.StreamShape;
34 private final StreamShape shape;
37 this(flags, StreamShape.REFERENCE); in FlagDeclaringOp()
40 public FlagDeclaringOp(int flags, StreamShape shape) { in FlagDeclaringOp()
46 public StreamShape outputShape() { in outputShape()
51 public StreamShape inputShape() { in inputShape()
DTestFlagExpectedOp.java34 StreamShape shape = StreamShape.REFERENCE;
59 Builder<T> shape(StreamShape shape) { in shape()
72 final StreamShape shape;
78 this(flags, known, preserve, notKnown, StreamShape.REFERENCE); in TestFlagExpectedOp()
85 StreamShape shape) { in TestFlagExpectedOp()
94 public StreamShape outputShape() { in outputShape()
99 public StreamShape inputShape() { in inputShape()
DStatelessTestOp.java30 import java.util.stream.StreamShape;
75 default StreamShape inputShape() { return StreamShape.REFERENCE; }
77 default StreamShape outputShape() { return StreamShape.REFERENCE; }
DOpTestCase.java55 private final Map<StreamShape, Set<? extends BaseStreamTestScenario>> testScenarios;
58 testScenarios = new EnumMap<>(StreamShape.class); in OpTestCase()
59 …testScenarios.put(StreamShape.REFERENCE, Collections.unmodifiableSet(EnumSet.allOf(StreamTestScena… in OpTestCase()
60 …testScenarios.put(StreamShape.INT_VALUE, Collections.unmodifiableSet(EnumSet.allOf(IntStreamTestSc… in OpTestCase()
61 …testScenarios.put(StreamShape.LONG_VALUE, Collections.unmodifiableSet(EnumSet.allOf(LongStreamTest… in OpTestCase()
62 …testScenarios.put(StreamShape.DOUBLE_VALUE, Collections.unmodifiableSet(EnumSet.allOf(DoubleStream… in OpTestCase()
92 StreamShape getShape(); in getShape()
252 final StreamShape shape;
450 default R run(Function<S_OUT, R> terminalF, S_OUT source, StreamShape shape) { in run()
461 public Object run(Function terminalF, BaseStream source, StreamShape shape) { in SINGLE_SEQUENTIAL_SHORT_CIRCUIT()
[all …]
DStatefulTestOp.java122 default StreamShape inputShape() { return StreamShape.REFERENCE; }
124 default StreamShape outputShape() { return StreamShape.REFERENCE; }
DTestData.java58 StreamShape getShape(); in getShape()
213 private final StreamShape shape;
221 StreamShape shape, in AbstractTestData()
237 public StreamShape getShape() { in getShape()
276 super(name, StreamShape.REFERENCE, state, streamFn, parStreamFn, splitrFn, sizeFn); in RefTestData()
291 super(name, StreamShape.INT_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in IntTestData()
316 super(name, StreamShape.LONG_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in LongTestData()
341 … super(name, StreamShape.DOUBLE_VALUE, state, streamFn, parStreamFn, splitrFn, sizeFn); in DoubleTestData()
/libcore/ojluni/src/main/java/java/util/stream/
DMatchOps.java97 return new MatchOp<>(StreamShape.REFERENCE, matchKind, MatchSink::new); in makeRef()
126 return new MatchOp<>(StreamShape.INT_VALUE, matchKind, MatchSink::new); in makeInt()
156 return new MatchOp<>(StreamShape.LONG_VALUE, matchKind, MatchSink::new); in makeLong()
186 return new MatchOp<>(StreamShape.DOUBLE_VALUE, matchKind, MatchSink::new); in makeDouble()
197 private final StreamShape inputShape;
209 MatchOp(StreamShape shape, in MatchOp()
223 public StreamShape inputShape() { in inputShape()
DIntPipeline.java136 public final StreamShape getOutputShape() { in getOutputShape()
137 return StreamShape.INT_VALUE; in getOutputShape()
196 return new LongPipeline.StatelessOp<Integer>(this, StreamShape.INT_VALUE, in asLongStream()
212 return new DoublePipeline.StatelessOp<Integer>(this, StreamShape.INT_VALUE,
235 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE,
253 return new ReferencePipeline.StatelessOp<Integer, U>(this, StreamShape.INT_VALUE,
271 return new LongPipeline.StatelessOp<Integer>(this, StreamShape.INT_VALUE,
289 return new DoublePipeline.StatelessOp<Integer>(this, StreamShape.INT_VALUE,
306 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE,
334 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE, StreamOpFlag.NOT_ORDERED) {
[all …]
DReduceOps.java88 return new ReduceOp<T, U, ReducingSink>(StreamShape.REFERENCE) { in makeRef()
138 return new ReduceOp<T, Optional<T>, ReducingSink>(StreamShape.REFERENCE) {
177 return new ReduceOp<T, I, ReducingSink>(StreamShape.REFERENCE) {
228 return new ReduceOp<T, R, ReducingSink>(StreamShape.REFERENCE) {
271 return new ReduceOp<Integer, Integer, ReducingSink>(StreamShape.INT_VALUE) {
321 return new ReduceOp<Integer, OptionalInt, ReducingSink>(StreamShape.INT_VALUE) {
364 return new ReduceOp<Integer, R, ReducingSink>(StreamShape.INT_VALUE) {
407 return new ReduceOp<Long, Long, ReducingSink>(StreamShape.LONG_VALUE) {
457 return new ReduceOp<Long, OptionalLong, ReducingSink>(StreamShape.LONG_VALUE) {
500 return new ReduceOp<Long, R, ReducingSink>(StreamShape.LONG_VALUE) {
[all …]
DLongPipeline.java134 public final StreamShape getOutputShape() { in getOutputShape()
135 return StreamShape.LONG_VALUE; in getOutputShape()
193 return new DoublePipeline.StatelessOp<Long>(this, StreamShape.LONG_VALUE, in asDoubleStream()
216 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE,
234 return new ReferencePipeline.StatelessOp<Long, U>(this, StreamShape.LONG_VALUE,
252 return new IntPipeline.StatelessOp<Long>(this, StreamShape.LONG_VALUE,
270 return new DoublePipeline.StatelessOp<Long>(this, StreamShape.LONG_VALUE,
287 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE,
315 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE, StreamOpFlag.NOT_ORDERED) {
327 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE,
[all …]
DFindOps.java58 return new FindOp<>(mustFindFirst, StreamShape.REFERENCE, Optional.empty(), in makeRef()
70 return new FindOp<>(mustFindFirst, StreamShape.INT_VALUE, OptionalInt.empty(), in makeInt()
82 return new FindOp<>(mustFindFirst, StreamShape.LONG_VALUE, OptionalLong.empty(), in makeLong()
94 return new FindOp<>(mustFindFirst, StreamShape.DOUBLE_VALUE, OptionalDouble.empty(), in makeDouble()
109 private final StreamShape shape;
128 StreamShape shape, in FindOp()
145 public StreamShape inputShape() { in inputShape()
DReferencePipeline.java103 public final StreamShape getOutputShape() { in getOutputShape()
104 return StreamShape.REFERENCE; in getOutputShape()
159 … return new StatelessOp<P_OUT, P_OUT>(this, StreamShape.REFERENCE, StreamOpFlag.NOT_ORDERED) { in unordered()
171 return new StatelessOp<P_OUT, P_OUT>(this, StreamShape.REFERENCE,
196 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
213 return new IntPipeline.StatelessOp<P_OUT>(this, StreamShape.REFERENCE,
231 return new LongPipeline.StatelessOp<P_OUT>(this, StreamShape.REFERENCE,
249 return new DoublePipeline.StatelessOp<P_OUT>(this, StreamShape.REFERENCE,
268 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
295 return new IntPipeline.StatelessOp<P_OUT>(this, StreamShape.REFERENCE,
[all …]
DNode.java175 default StreamShape getShape() { in getShape()
176 return StreamShape.REFERENCE; in getShape()
380 default StreamShape getShape() { in getShape()
381 return StreamShape.INT_VALUE; in getShape()
453 default StreamShape getShape() { in getShape()
454 return StreamShape.LONG_VALUE; in getShape()
529 default StreamShape getShape() { in getShape()
530 return StreamShape.DOUBLE_VALUE; in getShape()
DDoublePipeline.java133 public final StreamShape getOutputShape() { in getOutputShape()
134 return StreamShape.DOUBLE_VALUE; in getOutputShape()
198 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE, in map()
216 return new ReferencePipeline.StatelessOp<Double, U>(this, StreamShape.DOUBLE_VALUE,
234 return new IntPipeline.StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE,
252 return new LongPipeline.StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE,
269 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE,
297 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE, StreamOpFlag.NOT_ORDERED) {
309 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE,
333 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE,
[all …]
DTerminalOp.java53 default StreamShape inputShape() { return StreamShape.REFERENCE; } in inputShape()
DForEachOps.java199 public StreamShape inputShape() { in inputShape()
200 return StreamShape.INT_VALUE; in inputShape()
220 public StreamShape inputShape() { in inputShape()
221 return StreamShape.LONG_VALUE; in inputShape()
241 public StreamShape inputShape() { in inputShape()
242 return StreamShape.DOUBLE_VALUE; in inputShape()
DStreamShape.java51 public enum StreamShape { enum

12