/libcore/ojluni/src/main/java/java/util/stream/ |
H A D | DistinctOps.java | 51 * @param upstream a reference stream with element type T 54 static <T> ReferencePipeline<T, T> makeRef(AbstractPipeline<?, T, ?> upstream) { argument 55 return new ReferencePipeline.StatefulOp<T, T>(upstream, StreamShape.REFERENCE,
|
H A D | SliceOps.java | 109 * @param upstream a reference stream with element type T 114 public static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, argument 119 return new ReferencePipeline.StatefulOp<T, T>(upstream, StreamShape.REFERENCE, 225 * @param upstream An IntStream 230 public static IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream, argument 235 return new IntPipeline.StatefulOp<Integer>(upstream, StreamShape.INT_VALUE, 334 * @param upstream A LongStream 339 public static LongStream makeLong(AbstractPipeline<?, Long, ?> upstream, argument 344 return new LongPipeline.StatefulOp<Long>(upstream, StreamShape.LONG_VALUE, 443 * @param upstream 448 makeDouble(AbstractPipeline<?, Double, ?> upstream, long skip, long limit) argument [all...] |
H A D | SortedOps.java | 48 * @param upstream a reference stream with element type T 50 static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream) { argument 51 return new OfRef<>(upstream); 58 * @param upstream a reference stream with element type T 61 static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, argument 63 return new OfRef<>(upstream, comparator); 70 * @param upstream a reference stream with element type T 72 static <T> IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream) { argument 73 return new OfInt(upstream); 80 * @param upstream 82 makeLong(AbstractPipeline<?, Long, ?> upstream) argument 92 makeDouble(AbstractPipeline<?, Double, ?> upstream) argument 110 OfRef(AbstractPipeline<?, T, ?> upstream) argument 125 OfRef(AbstractPipeline<?, T, ?> upstream, Comparator<? super T> comparator) argument 168 OfInt(AbstractPipeline<?, Integer, ?> upstream) argument 207 OfLong(AbstractPipeline<?, Long, ?> upstream) argument 246 OfDouble(AbstractPipeline<?, Double, ?> upstream) argument [all...] |
H A D | DoublePipeline.java | 50 * @param <E_IN> type of elements in the upstream source 87 * @param upstream the upstream element source. 90 DoublePipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { argument 91 super(upstream, opFlags); 516 * @param <E_IN> type of elements in the upstream source 584 * @param <E_IN> type of elements in the upstream source 593 * @param upstream the upstream pipeline stage 594 * @param inputShape the stream shape for the upstream pipelin 597 StatelessOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument 626 StatefulOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument [all...] |
H A D | IntPipeline.java | 50 * @param <E_IN> type of elements in the upstream source 88 * @param upstream the upstream element source 91 IntPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { argument 92 super(upstream, opFlags); 512 * @param <E_IN> type of elements in the upstream source 580 * @param <E_IN> type of elements in the upstream source 588 * @param upstream The upstream pipeline stage 589 * @param inputShape The stream shape for the upstream pipelin 592 StatelessOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument 620 StatefulOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument [all...] |
H A D | LongPipeline.java | 51 * @param <E_IN> type of elements in the upstream source 88 * @param upstream the upstream element source. 91 LongPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { argument 92 super(upstream, opFlags); 495 * @param <E_IN> type of elements in the upstream source 560 * @param <E_IN> type of elements in the upstream source 568 * @param upstream The upstream pipeline stage 569 * @param inputShape The stream shape for the upstream pipelin 572 StatelessOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument 601 StatefulOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument [all...] |
H A D | ReferencePipeline.java | 52 * @param <P_IN> type of elements in the upstream source 92 * @param upstream the upstream element source. 94 ReferencePipeline(AbstractPipeline<?, P_IN, ?> upstream, int opFlags) { argument 95 super(upstream, opFlags); 537 * @param <E_IN> type of elements in the upstream source 604 * @param <E_IN> type of elements in the upstream source 615 * @param upstream The upstream pipeline stage 616 * @param inputShape The stream shape for the upstream pipelin 619 StatelessOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument 649 StatefulOp(AbstractPipeline<?, E_IN, ?> upstream, StreamShape inputShape, int opFlags) argument [all...] |
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
H A D | IntermediateTestOp.java | 31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 34 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); 37 return StatefulTestOp.chain(upstream, (StatefulTestOp) op);
|
H A D | StatelessTestOp.java | 31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 36 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { 42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 55 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
|
H A D | StatefulTestOp.java | 34 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 38 return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { 58 return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 78 return new LongPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 98 return new DoublePipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) {
|
H A D | TestFlagExpectedOp.java | 104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument 106 return upstream;
|
H A D | OpTestCase.java | 617 private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { argument 618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op);
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
H A D | IntermediateTestOp.java | 33 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 36 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); 39 return StatefulTestOp.chain(upstream, (StatefulTestOp) op);
|
H A D | StatelessTestOp.java | 39 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 44 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { 51 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 58 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 65 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
|
H A D | TestFlagExpectedOp.java | 105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument 107 return upstream;
|
H A D | StatefulTestOp.java | 35 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument 39 return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { 59 return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 79 return new LongPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 99 return new DoublePipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) {
|
H A D | OpTestCase.java | 618 private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { argument 619 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op);
|
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
H A D | FlagOpTest.java | 55 TestFlagPassThroughOp<T> upstream; field in class:FlagOpTest.TestFlagPassThroughOp 62 void set(TestFlagPassThroughOp<T> upstream, TestFlagPassThroughOp<T> downstream) { argument 63 this.upstream = upstream; 264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument 266 return upstream;
|