| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | AbstractPipeline.java | 74 public abstract class AbstractPipeline<E_IN, E_OUT, S extends BaseStream<E_OUT, S>> class
84 private final AbstractPipeline sourceStage;
90 private final AbstractPipeline previousStage;
103 private AbstractPipeline nextStage;
161 AbstractPipeline(Supplier<? extends Spliterator<?>> source, in AbstractPipeline() method in AbstractPipeline
182 AbstractPipeline(Spliterator<?> source, in AbstractPipeline() method in AbstractPipeline
203 AbstractPipeline(AbstractPipeline<?, E_IN, ?> previousStage, int opFlags) { in AbstractPipeline() method in AbstractPipeline
418 …for (@SuppressWarnings("rawtypes") AbstractPipeline u = sourceStage, p = sourceStage.nextStage, e … in sourceSpliterator()
461 AbstractPipeline p = AbstractPipeline.this; in getSourceShape()
497 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 | 56 extends AbstractPipeline<E_IN, Integer, IntStream>
92 IntPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in IntPipeline() argument
106 Tripwire.trip(AbstractPipeline.class, in adapt()
125 Tripwire.trip(AbstractPipeline.class, in adapt()
615 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
646 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | DoublePipeline.java | 57 extends AbstractPipeline<E_IN, Double, DoubleStream>
91 DoublePipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in DoublePipeline() argument
104 Tripwire.trip(AbstractPipeline.class, in adapt()
122 Tripwire.trip(AbstractPipeline.class, in adapt()
619 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
651 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | LongPipeline.java | 57 extends AbstractPipeline<E_IN, Long, LongStream>
92 LongPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in LongPipeline() argument
105 Tripwire.trip(AbstractPipeline.class, in adapt()
123 Tripwire.trip(AbstractPipeline.class, in adapt()
595 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
627 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | SliceOps.java | 114 public static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, in makeRef() argument
233 public static IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream,
345 public static LongStream makeLong(AbstractPipeline<?, Long, ?> upstream,
457 public static DoubleStream makeDouble(AbstractPipeline<?, Double, ?> upstream,
573 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
580 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
|
| D | ReferencePipeline.java | 60 extends AbstractPipeline<P_IN, P_OUT, Stream<P_OUT>>
95 ReferencePipeline(AbstractPipeline<?, P_IN, ?> upstream, int opFlags) { in ReferencePipeline() argument
642 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
675 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 | 1065 "ojluni/src/main/java/java/util/stream/AbstractPipeline.java",
|