| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | CollectorOps.java | 34 public static <E_IN> StatefulTestOp<E_IN> collector() { in collector()
39 public static class StatefulCollector<E_IN> implements StatefulTestOp<E_IN> {
64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { in opWrapSink()
69 public <P_IN> Node<E_IN> opEvaluateParallel(PipelineHelper<E_IN> helper, in opEvaluateParallel()
71 IntFunction<E_IN[]> generator) { in opEvaluateParallel()
|
| D | StatelessTestOp.java | 28 interface StatelessTestOp<E_IN, E_OUT> extends IntermediateTestOp<E_IN, E_OUT> {
71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
|
| D | IntermediateTestOp.java | 28 interface IntermediateTestOp<E_IN, E_OUT> {
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | CollectorOps.java | 35 public static <E_IN> StatefulTestOp<E_IN> collector() { in collector()
40 public static class StatefulCollector<E_IN> implements StatefulTestOp<E_IN> {
65 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { in opWrapSink()
70 public <P_IN> Node<E_IN> opEvaluateParallel(PipelineHelper<E_IN> helper, in opEvaluateParallel()
72 IntFunction<E_IN[]> generator) { in opEvaluateParallel()
|
| D | StatelessTestOp.java | 36 interface StatelessTestOp<E_IN, E_OUT> extends IntermediateTestOp<E_IN, E_OUT> {
81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
|
| D | IntermediateTestOp.java | 30 interface IntermediateTestOp<E_IN, E_OUT> {
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | TerminalOp.java | 45 interface TerminalOp<E_IN, R> {
80 default <P_IN> R evaluateParallel(PipelineHelper<E_IN> helper, in evaluateParallel()
96 <P_IN> R evaluateSequential(PipelineHelper<E_IN> helper, in evaluateSequential()
|
| D | IntPipeline.java | 55 public abstract class IntPipeline<E_IN>
56 extends AbstractPipeline<E_IN, Integer, IntStream>
92 IntPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in IntPipeline() argument
594 public static class Head<E_IN> extends IntPipeline<E_IN> {
632 public final Sink<E_IN> opWrapSink(int flags, Sink<Integer> sink) {
667 public abstract static class StatelessOp<E_IN> extends IntPipeline<E_IN> {
676 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
698 public abstract static class StatefulOp<E_IN> extends IntPipeline<E_IN> {
707 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | LongPipeline.java | 56 public abstract class LongPipeline<E_IN>
57 extends AbstractPipeline<E_IN, Long, LongStream>
92 LongPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in LongPipeline() argument
578 public static class Head<E_IN> extends LongPipeline<E_IN> {
616 public final Sink<E_IN> opWrapSink(int flags, Sink<Long> sink) {
648 public abstract static class StatelessOp<E_IN> extends LongPipeline<E_IN> {
657 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
679 public abstract static class StatefulOp<E_IN> extends LongPipeline<E_IN> {
689 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | DoublePipeline.java | 56 public abstract class DoublePipeline<E_IN>
57 extends AbstractPipeline<E_IN, Double, DoubleStream>
91 DoublePipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in DoublePipeline() argument
601 public static class Head<E_IN> extends DoublePipeline<E_IN> {
639 public final Sink<E_IN> opWrapSink(int flags, Sink<Double> sink) {
675 public abstract static class StatelessOp<E_IN> extends DoublePipeline<E_IN> {
685 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
707 public abstract static class StatefulOp<E_IN> extends DoublePipeline<E_IN> {
717 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | ReferencePipeline.java | 747 public static class Head<E_IN, E_OUT> extends ReferencePipeline<E_IN, E_OUT> {
783 public final Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink) {
819 public abstract static class StatelessOp<E_IN, E_OUT>
820 extends ReferencePipeline<E_IN, E_OUT> {
830 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
853 public abstract static class StatefulOp<E_IN, E_OUT>
854 extends ReferencePipeline<E_IN, E_OUT> {
863 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | AbstractPipeline.java | 74 public abstract class AbstractPipeline<E_IN, E_OUT, S extends BaseStream<E_OUT, S>>
203 AbstractPipeline(AbstractPipeline<?, E_IN, ?> previousStage, int opFlags) { in AbstractPipeline() argument
704 public abstract Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink); in opWrapSink()
|