Home
last modified time | relevance | path

Searched refs:P_OUT (Results 1 – 11 of 11) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DReferencePipeline.java63 public abstract class ReferencePipeline<P_IN, P_OUT>
64 extends AbstractPipeline<P_IN, P_OUT, Stream<P_OUT>>
65 implements Stream<P_OUT> {
113 public final <P_IN> Node<P_OUT> evaluateToNode(PipelineHelper<P_OUT> helper, in evaluateToNode()
116 IntFunction<P_OUT[]> generator) { in evaluateToNode()
122 public final <P_IN> Spliterator<P_OUT> wrap(PipelineHelper<P_OUT> ph, in wrap()
130 … public final Spliterator<P_OUT> lazySpliterator(Supplier<? extends Spliterator<P_OUT>> supplier) { in lazySpliterator()
136 public final boolean forEachWithCancel(Spliterator<P_OUT> spliterator, Sink<P_OUT> sink) { in forEachWithCancel()
144 …public final Node.Builder<P_OUT> makeNodeBuilder(long exactSizeIfKnown, IntFunction<P_OUT[]> gener… in makeNodeBuilder()
152 public final Iterator<P_OUT> iterator() { in iterator()
[all …]
DPipelineHelper.java57 public abstract class PipelineHelper<P_OUT> {
111 abstract<P_IN, S extends Sink<P_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator); in wrapAndCopyInto()
159 public abstract<P_IN> Sink<P_IN> wrapSink(Sink<P_OUT> sink); in wrapSink()
167 abstract<P_IN> Spliterator<P_OUT> wrapSpliterator(Spliterator<P_IN> spliterator); in wrapSpliterator()
181 abstract Node.Builder<P_OUT> makeNodeBuilder(long exactSizeIfKnown, in makeNodeBuilder()
182 IntFunction<P_OUT[]> generator); in makeNodeBuilder()
207 public abstract<P_IN> Node<P_OUT> evaluate(Spliterator<P_IN> spliterator, in evaluate()
209 IntFunction<P_OUT[]> generator); in evaluate()
DSliceOps.java585 private static final class SliceTask<P_IN, P_OUT>
586 extends AbstractShortCircuitTask<P_IN, P_OUT, Node<P_OUT>, SliceTask<P_IN, P_OUT>> {
587 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
588 private final IntFunction<P_OUT[]> generator;
594 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
595 PipelineHelper<P_OUT> helper,
597 IntFunction<P_OUT[]> generator,
606 SliceTask(SliceTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator) {
615 protected SliceTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) {
620 protected final Node<P_OUT> getEmptyResult() {
[all …]
DWhileOps.java1189 private static final class TakeWhileTask<P_IN, P_OUT>
1190 extends AbstractShortCircuitTask<P_IN, P_OUT, Node<P_OUT>, TakeWhileTask<P_IN, P_OUT>> {
1191 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
1192 private final IntFunction<P_OUT[]> generator;
1200 TakeWhileTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
1201 PipelineHelper<P_OUT> helper,
1203 IntFunction<P_OUT[]> generator) {
1210 TakeWhileTask(TakeWhileTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator) {
1218 protected TakeWhileTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) {
1223 protected final Node<P_OUT> getEmptyResult() {
[all …]
DMatchOps.java278 private static final class MatchTask<P_IN, P_OUT>
279 extends AbstractShortCircuitTask<P_IN, P_OUT, Boolean, MatchTask<P_IN, P_OUT>> {
280 private final MatchOp<P_OUT> op;
285 MatchTask(MatchOp<P_OUT> op, PipelineHelper<P_OUT> helper, in MatchTask()
294 MatchTask(MatchTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator) { in MatchTask()
300 protected MatchTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) { in makeChild()
DFindOps.java280 private static final class FindTask<P_IN, P_OUT, O>
281 extends AbstractShortCircuitTask<P_IN, P_OUT, O, FindTask<P_IN, P_OUT, O>> {
282 private final FindOp<P_OUT, O> op;
285 FindTask(FindOp<P_OUT, O> op, in FindTask() argument
287 PipelineHelper<P_OUT> helper, in FindTask()
294 FindTask(FindTask<P_IN, P_OUT, O> parent, Spliterator<P_IN> spliterator) { in FindTask() argument
301 protected FindTask<P_IN, P_OUT, O> makeChild(Spliterator<P_IN> spliterator) { in makeChild()
338 for (FindTask<P_IN, P_OUT, O> child = leftChild, p = null; child != p; in onCompletion()
DNodes.java324 public static <P_IN, P_OUT> Node<P_OUT> collect(PipelineHelper<P_OUT> helper, in collect()
327 IntFunction<P_OUT[]> generator) { in collect()
332 P_OUT[] array = generator.apply((int) size); in collect()
336 Node<P_OUT> node = new CollectorTask.OfRef<>(helper, generator, spliterator).invoke(); in collect()
1830 private abstract static class SizedCollectorTask<P_IN, P_OUT, T_SINK extends Sink<P_OUT>,
1831 … K extends SizedCollectorTask<P_IN, P_OUT, T_SINK, K>>
1833 implements Sink<P_OUT> {
1835 protected final PipelineHelper<P_OUT> helper;
1843 PipelineHelper<P_OUT> helper,
1872 SizedCollectorTask<P_IN, P_OUT, T_SINK, K> task = this;
[all …]
DAbstractShortCircuitTask.java43 abstract class AbstractShortCircuitTask<P_IN, P_OUT, R,
44 K extends AbstractShortCircuitTask<P_IN, P_OUT, R, K>>
45 extends AbstractTask<P_IN, P_OUT, R, K> {
68 protected AbstractShortCircuitTask(PipelineHelper<P_OUT> helper, in AbstractShortCircuitTask()
DAbstractTask.java88 abstract class AbstractTask<P_IN, P_OUT, R,
89 K extends AbstractTask<P_IN, P_OUT, R, K>>
95 protected final PipelineHelper<P_OUT> helper;
131 protected AbstractTask(PipelineHelper<P_OUT> helper, in AbstractTask()
DStreamSpliterators.java60 private abstract static class AbstractWrappingSpliterator<P_IN, P_OUT,
62 implements Spliterator<P_OUT> {
72 final PipelineHelper<P_OUT> ph;
115 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, in AbstractWrappingSpliterator()
128 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, in AbstractWrappingSpliterator()
179 abstract AbstractWrappingSpliterator<P_IN, P_OUT, ?> wrap(Spliterator<P_IN> s);
188 public Spliterator<P_OUT> trySplit() {
255 public Comparator<? super P_OUT> getComparator() {
267 static final class WrappingSpliterator<P_IN, P_OUT>
268 extends AbstractWrappingSpliterator<P_IN, P_OUT, SpinedBuffer<P_OUT>> {
[all …]
DReduceOps.java935 private static final class ReduceTask<P_IN, P_OUT, R,
936 S extends AccumulatingSink<P_OUT, R, S>>
937 extends AbstractTask<P_IN, P_OUT, S, ReduceTask<P_IN, P_OUT, R, S>> {
938 private final ReduceOp<P_OUT, R, S> op;
940 ReduceTask(ReduceOp<P_OUT, R, S> op,
941 PipelineHelper<P_OUT> helper,
947 ReduceTask(ReduceTask<P_IN, P_OUT, R, S> parent,
954 protected ReduceTask<P_IN, P_OUT, R, S> makeChild(Spliterator<P_IN> spliterator) {