| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | AbstractPipeline.java | 73 public abstract class AbstractPipeline<E_IN, E_OUT, S extends BaseStream<E_OUT, S>> class
83 private final AbstractPipeline sourceStage;
89 private final AbstractPipeline previousStage;
102 private AbstractPipeline nextStage;
160 AbstractPipeline(Supplier<? extends Spliterator<?>> source, in AbstractPipeline() method in AbstractPipeline
181 AbstractPipeline(Spliterator<?> source, in AbstractPipeline() method in AbstractPipeline
202 AbstractPipeline(AbstractPipeline<?, E_IN, ?> previousStage, int opFlags) { in AbstractPipeline() method in AbstractPipeline
415 …for (@SuppressWarnings("rawtypes") AbstractPipeline u = sourceStage, p = sourceStage.nextStage, e … in sourceSpliterator()
458 AbstractPipeline p = AbstractPipeline.this; in getSourceShape()
494 AbstractPipeline p = AbstractPipeline.this; in copyIntoWithCancel()
[all …]
|
| D | SortedOps.java | 50 static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream) { in makeRef() argument
61 static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, in makeRef() argument
72 static <T> IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream) { in makeInt() argument
82 static <T> LongStream makeLong(AbstractPipeline<?, Long, ?> upstream) { in makeLong() argument
92 static <T> DoubleStream makeDouble(AbstractPipeline<?, Double, ?> upstream) { in makeDouble() argument
110 OfRef(AbstractPipeline<?, T, ?> upstream) { in OfRef() argument
125 OfRef(AbstractPipeline<?, T, ?> upstream, Comparator<? super T> comparator) { in OfRef() argument
168 OfInt(AbstractPipeline<?, Integer, ?> upstream) { in OfInt() argument
207 OfLong(AbstractPipeline<?, Long, ?> upstream) { in OfLong() argument
246 OfDouble(AbstractPipeline<?, Double, ?> upstream) { in OfDouble() argument
|
| D | IntPipeline.java | 55 extends AbstractPipeline<E_IN, Integer, IntStream>
91 IntPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in IntPipeline() argument
105 Tripwire.trip(AbstractPipeline.class, in adapt()
124 Tripwire.trip(AbstractPipeline.class, in adapt()
592 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
620 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | DoublePipeline.java | 56 extends AbstractPipeline<E_IN, Double, DoubleStream>
90 DoublePipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in DoublePipeline() argument
103 Tripwire.trip(AbstractPipeline.class, in adapt()
121 Tripwire.trip(AbstractPipeline.class, in adapt()
597 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
626 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | LongPipeline.java | 56 extends AbstractPipeline<E_IN, Long, LongStream>
91 LongPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in LongPipeline() argument
104 Tripwire.trip(AbstractPipeline.class, in adapt()
122 Tripwire.trip(AbstractPipeline.class, in adapt()
572 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
601 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | SliceOps.java | 114 public static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, in makeRef() argument
230 public static IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream,
339 public static LongStream makeLong(AbstractPipeline<?, Long, ?> upstream,
448 public static DoubleStream makeDouble(AbstractPipeline<?, Double, ?> upstream,
561 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
568 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
|
| D | ReferencePipeline.java | 59 extends AbstractPipeline<P_IN, P_OUT, Stream<P_OUT>>
94 ReferencePipeline(AbstractPipeline<?, P_IN, ?> upstream, int opFlags) { in ReferencePipeline() argument
619 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
649 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | DistinctOps.java | 54 static <T> ReferencePipeline<T, T> makeRef(AbstractPipeline<?, T, ?> upstream) { in makeRef() argument
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | IntermediateTestOp.java | 25 import java.util.stream.AbstractPipeline;
33 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| D | StatelessTestOp.java | 25 import java.util.stream.AbstractPipeline;
39 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| D | OpTestCase.java | 67 return ((AbstractPipeline) s).getStreamFlags(); in getStreamFlags()
276 this.shape = ((AbstractPipeline<?, U, ?>) m.apply(data.stream())).getOutputShape(); in ExerciseDataStreamBuilder()
380 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
381 …Node<U> refNodeResult = ((AbstractPipeline<?, U, ?>) sOut).evaluateToArrayNode(size -> (U[]) new O… in exercise()
387 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
546 AbstractPipeline ap = (AbstractPipeline) out; in exercise()
585 … AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { in createPipeline()
618 …private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?… in chain()
619 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
623 … private static AbstractPipeline<?, ?, ?> chain(AbstractPipeline pipe, IntermediateTestOp... ops) { in chain()
[all …]
|
| D | StatefulTestOp.java | 35 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | IntermediateTestOp.java | 31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| D | OpTestCase.java | 66 return ((AbstractPipeline) s).getStreamFlags(); in getStreamFlags()
275 this.shape = ((AbstractPipeline<?, U, ?>) m.apply(data.stream())).getOutputShape(); in ExerciseDataStreamBuilder()
379 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
380 …Node<U> refNodeResult = ((AbstractPipeline<?, U, ?>) sOut).evaluateToArrayNode(size -> (U[]) new O… in exercise()
386 … isStreamOrdered = StreamOpFlag.ORDERED.isKnown(((AbstractPipeline) sOut).getStreamFlags()); in exercise()
545 AbstractPipeline ap = (AbstractPipeline) out; in exercise()
584 … AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { in createPipeline()
617 …private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?… in chain()
618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
622 … private static AbstractPipeline<?, ?, ?> chain(AbstractPipeline pipe, IntermediateTestOp... ops) { in chain()
[all …]
|
| D | StatelessTestOp.java | 31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| D | StatefulTestOp.java | 34 public static<T> AbstractPipeline chain(AbstractPipeline upstream, in chain()
|
| /libcore/ |
| D | openjdk_java_files.bp | 1064 "ojluni/src/main/java/java/util/stream/AbstractPipeline.java",
|