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()
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()
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()
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()
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()
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()
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()
387 return StreamOpFlag.toStreamFlags(combinedFlags); in getStreamFlags()
426 if (StreamOpFlag.SHORT_CIRCUIT.isKnown(thisOpFlags)) { in sourceSpliterator()
432 thisOpFlags = thisOpFlags & ~StreamOpFlag.IS_SHORT_CIRCUIT; in sourceSpliterator()
440 ? (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.java159 … return new StatelessOp<P_OUT, P_OUT>(this, StreamShape.REFERENCE, StreamOpFlag.NOT_ORDERED) { in unordered()
172 StreamOpFlag.NOT_SIZED) {
197 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
214 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
232 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
250 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
269 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
296 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
325 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
354 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
DIntPipeline.java197 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asLongStream()
213 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
236 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
254 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
272 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
290 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
307 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
334 return new StatelessOp<Integer>(this, StreamShape.INT_VALUE, StreamOpFlag.NOT_ORDERED) {
347 StreamOpFlag.NOT_SIZED) {
DStreamOpFlag.java206 public enum StreamOpFlag { enum
447 private StreamOpFlag(int position, MaskBuilder maskBuilder) { in StreamOpFlag() method in StreamOpFlag
566 for (StreamOpFlag flag : StreamOpFlag.values()) { in createMask()
579 for (StreamOpFlag flag : StreamOpFlag.values()) { in createFlagMask()
716 return (prevCombOpFlags & StreamOpFlag.getMask(newStreamOrOpFlags)) | newStreamOrOpFlags; in combineOpFlags()
DLongPipeline.java194 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in asDoubleStream()
217 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
235 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
253 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
271 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
288 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
315 return new StatelessOp<Long>(this, StreamShape.LONG_VALUE, StreamOpFlag.NOT_ORDERED) {
328 StreamOpFlag.NOT_SIZED) {
DDoublePipeline.java199 StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) { in map()
217 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
235 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
253 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
270 … StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT | StreamOpFlag.NOT_SIZED) {
297 return new StatelessOp<Double>(this, StreamShape.DOUBLE_VALUE, StreamOpFlag.NOT_ORDERED) {
310 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)

12