Home
last modified time | relevance | path

Searched refs:StreamOpFlag (Results 1 – 25 of 37) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DStreamOpFlagsTest.java40 import static java.util.stream.StreamOpFlag.*;
48 int sourceFlags = StreamOpFlag.IS_SIZED; in testNullCombine()
50 …assertEquals(sourceFlags, toStreamFlags(combineOpFlags(sourceFlags, StreamOpFlag.INITIAL_OPS_VALUE… in testNullCombine()
54 List<StreamOpFlag> flags = new ArrayList<>(StreamOpFlagTestHelper.allStreamFlags()); in testInitialOpFlagsFromSourceFlags()
63 int opsFlags = combineOpFlags(sourceFlags, StreamOpFlag.INITIAL_OPS_VALUE); in testInitialOpFlagsFromSourceFlags()
64 assertEquals(opsFlags, (~(sourceFlags << 1)) & StreamOpFlag.INITIAL_OPS_VALUE); in testInitialOpFlagsFromSourceFlags()
69 for (StreamOpFlag f : StreamOpFlagTestHelper.allStreamFlags()) { in testSameCombine()
73 opsFlags = combineOpFlags(sourceFlags, StreamOpFlag.INITIAL_OPS_VALUE); in testSameCombine()
80 for (StreamOpFlag f : StreamOpFlagTestHelper.allStreamFlags()) { in testOpClear()
85 opsFlags = combineOpFlags(sourceFlags, StreamOpFlag.INITIAL_OPS_VALUE); in testOpClear()
[all …]
DFlagOpTest.java84 for (StreamOpFlag f : EnumSet.allOf(StreamOpFlag.class)) { in testFlagsClearAllSet()
90 EnumSet<StreamOpFlag> known = EnumSet.noneOf(StreamOpFlag.class); in testFlagsClearAllSet()
91 EnumSet<StreamOpFlag> notKnown = StreamOpFlagTestHelper.allStreamFlags(); in testFlagsClearAllSet()
95 for (StreamOpFlag f : StreamOpFlagTestHelper.allStreamFlags()) { in testFlagsClearAllSet()
96 if (f.canSet(StreamOpFlag.Type.OP)) { in testFlagsClearAllSet()
99 EnumSet.noneOf(StreamOpFlag.class), in testFlagsClearAllSet()
107 EnumSet.noneOf(StreamOpFlag.class), in testFlagsClearAllSet()
120 EnumSet<StreamOpFlag> known = StreamOpFlagTestHelper.allStreamFlags(); in testFlagsSetAllClear()
122 for (StreamOpFlag f : EnumSet.allOf(StreamOpFlag.class)) { in testFlagsSetAllClear()
124 if (f.canSet(StreamOpFlag.Type.OP)) { in testFlagsSetAllClear()
[all …]
DStreamFlagsTest.java29 import java.util.stream.StreamOpFlag;
32 import static java.util.stream.StreamOpFlag.*;
52 …private void assertFlags(int value, EnumSet<StreamOpFlag> setFlags, EnumSet<StreamOpFlag> clearFla… in assertFlags()
53 for (StreamOpFlag flag : setFlags) in assertFlags()
55 for (StreamOpFlag flag : clearFlags) in assertFlags()
83 EnumSet.noneOf(StreamOpFlag.class), in testBaseStreams()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DTestFlagExpectedOp.java35 EnumSet<StreamOpFlag> known = EnumSet.noneOf(StreamOpFlag.class);
36 EnumSet<StreamOpFlag> preserve = EnumSet.noneOf(StreamOpFlag.class);
37 EnumSet<StreamOpFlag> notKnown = EnumSet.noneOf(StreamOpFlag.class);
43 Builder<T> known(EnumSet<StreamOpFlag> known) { in known()
48 Builder<T> preserve(EnumSet<StreamOpFlag> preserve) { in preserve()
53 Builder<T> notKnown(EnumSet<StreamOpFlag> notKnown) { in notKnown()
68 final EnumSet<StreamOpFlag> known;
69 final EnumSet<StreamOpFlag> preserve;
70 final EnumSet<StreamOpFlag> notKnown;
74 EnumSet<StreamOpFlag> known, in TestFlagExpectedOp()
[all …]
DStreamOpFlagTestHelper.java30 private static final EnumSet<StreamOpFlag> allStreamFlags;
33 allStreamFlags = EnumSet.allOf(StreamOpFlag.class);
34 for (StreamOpFlag f : EnumSet.allOf(StreamOpFlag.class))
40 static EnumSet<StreamOpFlag> allStreamFlags() { in allStreamFlags()
46 return StreamOpFlag.ORDERED.isKnown(OpTestCase.getStreamFlags(s)); in isStreamOrdered()
DLongStreamTestScenario.java148 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
159 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
184 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DIntStreamTestScenario.java148 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
160 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
185 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DDoubleStreamTestScenario.java148 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
159 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
184 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DOpTestCase.java379 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
386 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
546 boolean isOrdered = StreamOpFlag.ORDERED.isKnown(ap.getStreamFlags()); in exercise()
555 … StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SIZED, in exercise()
566 StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SIZED, in exercise()
654 return StreamOpFlag.IS_SHORT_CIRCUIT; in opGetFlags()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DTestFlagExpectedOp.java36 EnumSet<StreamOpFlag> known = EnumSet.noneOf(StreamOpFlag.class);
37 EnumSet<StreamOpFlag> preserve = EnumSet.noneOf(StreamOpFlag.class);
38 EnumSet<StreamOpFlag> notKnown = EnumSet.noneOf(StreamOpFlag.class);
44 Builder<T> known(EnumSet<StreamOpFlag> known) { in known()
49 Builder<T> preserve(EnumSet<StreamOpFlag> preserve) { in preserve()
54 Builder<T> notKnown(EnumSet<StreamOpFlag> notKnown) { in notKnown()
69 final EnumSet<StreamOpFlag> known;
70 final EnumSet<StreamOpFlag> preserve;
71 final EnumSet<StreamOpFlag> notKnown;
75 EnumSet<StreamOpFlag> known, in TestFlagExpectedOp()
[all …]
DStreamOpFlagTestHelper.java27 import java.util.stream.StreamOpFlag;
33 private static final EnumSet<StreamOpFlag> allStreamFlags;
36 allStreamFlags = EnumSet.allOf(StreamOpFlag.class);
37 for (StreamOpFlag f : EnumSet.allOf(StreamOpFlag.class))
43 static EnumSet<StreamOpFlag> allStreamFlags() { in allStreamFlags()
49 return StreamOpFlag.ORDERED.isKnown(OpTestCase.getStreamFlags(s)); in isStreamOrdered()
DIntStreamTestScenario.java151 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
163 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
188 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DDoubleStreamTestScenario.java152 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
163 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
188 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DLongStreamTestScenario.java151 … StreamOpFlag.toCharacteristics(OpTestCase.getStreamFlags(s)) in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
162 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
187 … new FlagDeclaringOp(StreamOpFlag.NOT_SIZED, data.getShape())); in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DOpTestCase.java380 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
387 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
547 boolean isOrdered = StreamOpFlag.ORDERED.isKnown(ap.getStreamFlags()); in exercise()
556 … StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SIZED, in exercise()
567 StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SIZED, in exercise()
655 return StreamOpFlag.IS_SHORT_CIRCUIT; in opGetFlags()
/libcore/ojluni/src/main/java/java/util/stream/
DStreamSupport.java70 StreamOpFlag.fromCharacteristics(spliterator), in stream()
112 StreamOpFlag.fromCharacteristics(characteristics), in stream()
139 StreamOpFlag.fromCharacteristics(spliterator), in intStream()
179 StreamOpFlag.fromCharacteristics(characteristics), in intStream()
207 StreamOpFlag.fromCharacteristics(spliterator), in longStream()
247 StreamOpFlag.fromCharacteristics(characteristics), in longStream()
275 StreamOpFlag.fromCharacteristics(spliterator), in doubleStream()
315 StreamOpFlag.fromCharacteristics(characteristics), in doubleStream()
DAbstractPipeline.java165 this.sourceOrOpFlags = sourceFlags & StreamOpFlag.STREAM_MASK; in AbstractPipeline()
168 this.combinedFlags = (~(sourceOrOpFlags << 1)) & StreamOpFlag.INITIAL_OPS_VALUE; in AbstractPipeline()
186 this.sourceOrOpFlags = sourceFlags & StreamOpFlag.STREAM_MASK; in AbstractPipeline()
189 this.combinedFlags = (~(sourceOrOpFlags << 1)) & StreamOpFlag.INITIAL_OPS_VALUE; in AbstractPipeline()
209 this.sourceOrOpFlags = opFlags & StreamOpFlag.OP_MASK; in AbstractPipeline()
210 this.combinedFlags = StreamOpFlag.combineOpFlags(opFlags, previousStage.combinedFlags); in AbstractPipeline()
384 return StreamOpFlag.toStreamFlags(combinedFlags); in getStreamFlags()
423 if (StreamOpFlag.SHORT_CIRCUIT.isKnown(thisOpFlags)) { in sourceSpliterator()
429 thisOpFlags = thisOpFlags & ~StreamOpFlag.IS_SHORT_CIRCUIT; in sourceSpliterator()
437 ? (thisOpFlags & ~StreamOpFlag.NOT_SIZED) | StreamOpFlag.IS_SIZED in sourceSpliterator()
[all …]
DSortedOps.java112 StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SORTED); in OfRef()
127 StreamOpFlag.IS_ORDERED | StreamOpFlag.NOT_SORTED); in OfRef()
138 if (StreamOpFlag.SORTED.isKnown(flags) && isNaturalSort) in opWrapSink()
140 else if (StreamOpFlag.SIZED.isKnown(flags)) in opWrapSink()
152 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags()) && isNaturalSort) { in opEvaluateParallel()
170 StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SORTED); in OfInt()
177 if (StreamOpFlag.SORTED.isKnown(flags)) in opWrapSink()
179 else if (StreamOpFlag.SIZED.isKnown(flags)) in opWrapSink()
189 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags())) { in opEvaluateParallel()
209 StreamOpFlag.IS_ORDERED | StreamOpFlag.IS_SORTED); in OfLong()
[all …]
DDistinctOps.java56 … StreamOpFlag.IS_DISTINCT | StreamOpFlag.NOT_SIZED) { in makeRef()
71 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
75 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
104 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
108 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
122 if (StreamOpFlag.DISTINCT.isKnown(flags)) { in makeRef()
124 } else if (StreamOpFlag.SORTED.isKnown(flags)) { in makeRef()
DReferencePipeline.java152 … return new StatelessOp<P_OUT, P_OUT>(this, StreamShape.REFERENCE, StreamOpFlag.NOT_ORDERED) { in unordered()
164 StreamOpFlag.NOT_SIZED) {
188 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
205 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
222 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
239 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
257 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
284 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
312 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
340 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
DIntPipeline.java190 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asLongStream()
206 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
228 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
245 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
262 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
279 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
295 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
321 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE, StreamOpFlag.NOT_ORDERED) {
333 StreamOpFlag.NOT_SIZED) {
DStreamOpFlag.java205 public enum StreamOpFlag { enum
446 private StreamOpFlag(int position, MaskBuilder maskBuilder) { in StreamOpFlag() method in StreamOpFlag
553 for (StreamOpFlag flag : StreamOpFlag.values()) { in createMask()
566 for (StreamOpFlag flag : StreamOpFlag.values()) { in createFlagMask()
692 return (prevCombOpFlags & StreamOpFlag.getMask(newStreamOrOpFlags)) | newStreamOrOpFlags; in combineOpFlags()
DLongPipeline.java187 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asDoubleStream()
209 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
226 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
243 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
260 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
276 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
302 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE, StreamOpFlag.NOT_ORDERED) {
314 StreamOpFlag.NOT_SIZED) {
DDoublePipeline.java192 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in map()
209 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
226 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
243 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
259 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
285 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE, StreamOpFlag.NOT_ORDERED) {
297 StreamOpFlag.NOT_SIZED) {
DSliceOps.java140 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
172 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
257 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
281 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
366 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
390 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
475 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
499 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
549 return StreamOpFlag.NOT_SIZED | ((limit != -1) ? StreamOpFlag.IS_SHORT_CIRCUIT : 0);
601 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags)

12