| /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 | 54 public abstract class IntPipeline<E_IN>
55 extends AbstractPipeline<E_IN, Integer, IntStream>
91 IntPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in IntPipeline() argument
516 public static class Head<E_IN> extends IntPipeline<E_IN> {
550 public final Sink<E_IN> opWrapSink(int flags, Sink<Integer> sink) {
584 public abstract static class StatelessOp<E_IN> extends IntPipeline<E_IN> {
592 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
612 public abstract static class StatefulOp<E_IN> extends IntPipeline<E_IN> {
620 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | LongPipeline.java | 55 public abstract class LongPipeline<E_IN>
56 extends AbstractPipeline<E_IN, Long, LongStream>
91 LongPipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in LongPipeline() argument
499 public static class Head<E_IN> extends LongPipeline<E_IN> {
533 public final Sink<E_IN> opWrapSink(int flags, Sink<Long> sink) {
564 public abstract static class StatelessOp<E_IN> extends LongPipeline<E_IN> {
572 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
592 public abstract static class StatefulOp<E_IN> extends LongPipeline<E_IN> {
601 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | DoublePipeline.java | 55 public abstract class DoublePipeline<E_IN>
56 extends AbstractPipeline<E_IN, Double, DoubleStream>
90 DoublePipeline(AbstractPipeline<?, E_IN, ?> upstream, int opFlags) { in DoublePipeline() argument
519 public static class Head<E_IN> extends DoublePipeline<E_IN> {
553 public final Sink<E_IN> opWrapSink(int flags, Sink<Double> sink) {
588 public abstract static class StatelessOp<E_IN> extends DoublePipeline<E_IN> {
597 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
617 public abstract static class StatefulOp<E_IN> extends DoublePipeline<E_IN> {
626 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | ReferencePipeline.java | 542 public static class Head<E_IN, E_OUT> extends ReferencePipeline<E_IN, E_OUT> {
574 public final Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink) {
609 public abstract static class StatelessOp<E_IN, E_OUT>
610 extends ReferencePipeline<E_IN, E_OUT> {
619 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
640 public abstract static class StatefulOp<E_IN, E_OUT>
641 extends ReferencePipeline<E_IN, E_OUT> {
649 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | AbstractPipeline.java | 73 public abstract class AbstractPipeline<E_IN, E_OUT, S extends BaseStream<E_OUT, S>>
202 AbstractPipeline(AbstractPipeline<?, E_IN, ?> previousStage, int opFlags) { in AbstractPipeline() argument
659 public abstract Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink); in opWrapSink()
|