| /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 | 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
535 public static class Head<E_IN> extends DoublePipeline<E_IN> {
573 public final Sink<E_IN> opWrapSink(int flags, Sink<Double> sink) {
609 public abstract static class StatelessOp<E_IN> extends DoublePipeline<E_IN> {
619 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
641 public abstract static class StatefulOp<E_IN> extends DoublePipeline<E_IN> {
651 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| 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
533 public static class Head<E_IN> extends IntPipeline<E_IN> {
571 public final Sink<E_IN> opWrapSink(int flags, Sink<Integer> sink) {
606 public abstract static class StatelessOp<E_IN> extends IntPipeline<E_IN> {
615 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
637 public abstract static class StatefulOp<E_IN> extends IntPipeline<E_IN> {
646 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
516 public static class Head<E_IN> extends LongPipeline<E_IN> {
554 public final Sink<E_IN> opWrapSink(int flags, Sink<Long> sink) {
586 public abstract static class StatelessOp<E_IN> extends LongPipeline<E_IN> {
595 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
617 public abstract static class StatefulOp<E_IN> extends LongPipeline<E_IN> {
627 public StatefulOp(AbstractPipeline<?, E_IN, ?> upstream,
|
| D | ReferencePipeline.java | 559 public static class Head<E_IN, E_OUT> extends ReferencePipeline<E_IN, E_OUT> {
595 public final Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink) {
631 public abstract static class StatelessOp<E_IN, E_OUT>
632 extends ReferencePipeline<E_IN, E_OUT> {
642 public StatelessOp(AbstractPipeline<?, E_IN, ?> upstream,
665 public abstract static class StatefulOp<E_IN, E_OUT>
666 extends ReferencePipeline<E_IN, E_OUT> {
675 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
673 public abstract Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink); in opWrapSink()
|