Searched defs:upstream (Results 1 - 18 of 18) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
H A DDistinctOps.java51 * @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 DSliceOps.java109 * @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 DSortedOps.java48 * @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 DDoublePipeline.java50 * @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 DIntPipeline.java50 * @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 DLongPipeline.java51 * @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 DReferencePipeline.java52 * @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 DIntermediateTestOp.java31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument
34 return StatelessTestOp.chain(upstream, (StatelessTestOp) op);
37 return StatefulTestOp.chain(upstream, (StatefulTestOp) op);
H A DStatelessTestOp.java31 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 DStatefulTestOp.java34 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 DTestFlagExpectedOp.java104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
106 return upstream;
H A DOpTestCase.java617 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 DIntermediateTestOp.java33 public static<T> AbstractPipeline chain(AbstractPipeline upstream, argument
36 return StatelessTestOp.chain(upstream, (StatelessTestOp) op);
39 return StatefulTestOp.chain(upstream, (StatefulTestOp) op);
H A DStatelessTestOp.java39 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 DTestFlagExpectedOp.java105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
107 return upstream;
H A DStatefulTestOp.java35 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 DOpTestCase.java618 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 DFlagOpTest.java55 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;

Completed in 166 milliseconds