Home
last modified time | relevance | path

Searched refs:StreamOpFlag (Results 1 – 25 of 39) 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()
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()
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()
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()
/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()
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()
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()
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.java166 this.sourceOrOpFlags = sourceFlags & StreamOpFlag.STREAM_MASK; in AbstractPipeline()
169 this.combinedFlags = (~(sourceOrOpFlags << 1)) & StreamOpFlag.INITIAL_OPS_VALUE; in AbstractPipeline()
187 this.sourceOrOpFlags = sourceFlags & StreamOpFlag.STREAM_MASK; in AbstractPipeline()
190 this.combinedFlags = (~(sourceOrOpFlags << 1)) & StreamOpFlag.INITIAL_OPS_VALUE; in AbstractPipeline()
210 this.sourceOrOpFlags = opFlags & StreamOpFlag.OP_MASK; in AbstractPipeline()
211 this.combinedFlags = StreamOpFlag.combineOpFlags(opFlags, previousStage.combinedFlags); in AbstractPipeline()
390 return StreamOpFlag.toStreamFlags(combinedFlags); in getStreamFlags()
429 if (StreamOpFlag.SHORT_CIRCUIT.isKnown(thisOpFlags)) { in sourceSpliterator()
435 thisOpFlags = thisOpFlags & ~StreamOpFlag.IS_SHORT_CIRCUIT; in sourceSpliterator()
443 ? (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()
72 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
76 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
106 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
110 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
125 if (StreamOpFlag.DISTINCT.isKnown(flags)) { in makeRef()
127 } else if (StreamOpFlag.SORTED.isKnown(flags)) { in makeRef()
DReferencePipeline.java161 … return new StatelessOp<P_OUT, P_OUT>(this, StreamShape.REFERENCE, StreamOpFlag.NOT_ORDERED) { in unordered()
174 StreamOpFlag.NOT_SIZED) {
199 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
216 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
234 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
252 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
271 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
298 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
327 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
356 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
DIntPipeline.java199 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asLongStream()
215 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
238 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
256 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
274 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
292 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
309 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
336 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE, StreamOpFlag.NOT_ORDERED) {
349 StreamOpFlag.NOT_SIZED) {
DStreamOpFlag.java206 public enum StreamOpFlag { enum
459 private StreamOpFlag(int position, MaskBuilder maskBuilder) { in StreamOpFlag() method in StreamOpFlag
578 for (StreamOpFlag flag : StreamOpFlag.values()) { in createMask()
591 for (StreamOpFlag flag : StreamOpFlag.values()) { in createFlagMask()
734 return (prevCombOpFlags & StreamOpFlag.getMask(newStreamOrOpFlags)) | newStreamOrOpFlags; in combineOpFlags()
DLongPipeline.java196 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asDoubleStream()
219 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
237 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
255 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
273 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
290 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
317 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE, StreamOpFlag.NOT_ORDERED) {
330 StreamOpFlag.NOT_SIZED) {
DDoublePipeline.java201 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in map()
219 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
237 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
255 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
272 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
299 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE, StreamOpFlag.NOT_ORDERED) {
312 StreamOpFlag.NOT_SIZED) {
DSliceOps.java141 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
174 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
261 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
286 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
373 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
398 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
485 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
510 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
561 return StreamOpFlag.NOT_SIZED | ((limit != -1) ? StreamOpFlag.IS_SHORT_CIRCUIT : 0);
613 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags)
DWhileOps.java50 static final int TAKE_FLAGS = StreamOpFlag.NOT_SIZED | StreamOpFlag.IS_SHORT_CIRCUIT;
52 static final int DROP_FLAGS = StreamOpFlag.NOT_SIZED;
69 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeTakeWhileRef()
129 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
189 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
249 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
355 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
433 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
511 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
589 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {
[all …]

12