Home
last modified time | relevance | path

Searched refs:P_IN (Results 1 – 21 of 21) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DPipelineHelper.java94 abstract<P_IN> long exactOutputSizeIfKnown(Spliterator<P_IN> spliterator); in exactOutputSizeIfKnown()
110 abstract<P_IN, S extends Sink<P_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator); in wrapAndCopyInto()
127 abstract<P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyInto()
143 abstract <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyIntoWithCancel()
157 public abstract<P_IN> Sink<P_IN> wrapSink(Sink<P_OUT> sink); in wrapSink()
165 abstract<P_IN> Spliterator<P_OUT> wrapSpliterator(Spliterator<P_IN> spliterator); in wrapSpliterator()
205 public abstract<P_IN> Node<P_OUT> evaluate(Spliterator<P_IN> spliterator, in evaluate()
DAbstractPipeline.java469 final <P_IN> long exactOutputSizeIfKnown(Spliterator<P_IN> spliterator) { in exactOutputSizeIfKnown()
474 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) { in wrapAndCopyInto()
480 final <P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyInto()
495 final <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyIntoWithCancel()
519 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) { in wrapSink()
525 return (Sink<P_IN>) sink; in wrapSink()
530 final <P_IN> Spliterator<E_OUT> wrapSpliterator(Spliterator<P_IN> sourceSpliterator) { in wrapSpliterator()
542 public final <P_IN> Node<E_OUT> evaluate(Spliterator<P_IN> spliterator, in evaluate()
581 public abstract <P_IN> Node<E_OUT> evaluateToNode(PipelineHelper<E_OUT> helper, in evaluateToNode()
582 Spliterator<P_IN> spliterator, in evaluateToNode()
[all …]
DSliceOps.java76 private static <P_IN> Spliterator<P_IN> sliceSpliterator(StreamShape shape, in sliceSpliterator()
77 Spliterator<P_IN> s, in sliceSpliterator()
86 return (Spliterator<P_IN>) new StreamSpliterators in sliceSpliterator()
89 return (Spliterator<P_IN>) new StreamSpliterators in sliceSpliterator()
92 return (Spliterator<P_IN>) new StreamSpliterators in sliceSpliterator()
134 …public <P_IN> Spliterator<T> opEvaluateParallelLazy(PipelineHelper<T> helper, Spliterator<P_IN> sp… in makeRef()
162 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in makeRef()
163 Spliterator<P_IN> spliterator, in makeRef()
172 … Spliterator<P_IN> s = sliceSpliterator(helper.getSourceShape(), spliterator, skip, limit); in makeRef()
253 … public <P_IN> Spliterator<Integer> opEvaluateParallelLazy(PipelineHelper<Integer> helper,
[all …]
DTerminalOp.java80 default <P_IN> R evaluateParallel(PipelineHelper<E_IN> helper, in evaluateParallel()
81 Spliterator<P_IN> spliterator) { in evaluateParallel()
96 <P_IN> R evaluateSequential(PipelineHelper<E_IN> helper, in evaluateSequential()
97 Spliterator<P_IN> spliterator); in evaluateSequential()
DNodes.java316 public static <P_IN, P_OUT> Node<P_OUT> collect(PipelineHelper<P_OUT> helper, in collect()
317 Spliterator<P_IN> spliterator, in collect()
354 public static <P_IN> Node.OfInt collectInt(PipelineHelper<Integer> helper, in collectInt()
355 Spliterator<P_IN> spliterator, in collectInt()
392 public static <P_IN> Node.OfLong collectLong(PipelineHelper<Long> helper, in collectLong()
393 Spliterator<P_IN> spliterator, in collectLong()
430 public static <P_IN> Node.OfDouble collectDouble(PipelineHelper<Double> helper, in collectDouble()
431 Spliterator<P_IN> spliterator, in collectDouble()
1822 private static abstract class SizedCollectorTask<P_IN, P_OUT, T_SINK extends Sink<P_OUT>,
1823 … K extends SizedCollectorTask<P_IN, P_OUT, T_SINK, K>>
[all …]
DFindOps.java157 public <P_IN> O evaluateParallel(PipelineHelper<T> helper, in evaluateParallel()
158 Spliterator<P_IN> spliterator) { in evaluateParallel()
250 private static final class FindTask<P_IN, P_OUT, O>
251 extends AbstractShortCircuitTask<P_IN, P_OUT, O, FindTask<P_IN, P_OUT, O>> {
256 Spliterator<P_IN> spliterator) { in FindTask()
261 FindTask(FindTask<P_IN, P_OUT, O> parent, Spliterator<P_IN> spliterator) { in FindTask() argument
267 protected FindTask<P_IN, P_OUT, O> makeChild(Spliterator<P_IN> spliterator) { in makeChild()
304 for (FindTask<P_IN, P_OUT, O> child = leftChild, p = null; child != p; in onCompletion()
DAbstractTask.java87 abstract class AbstractTask<P_IN, P_OUT, R,
88 K extends AbstractTask<P_IN, P_OUT, R, K>>
106 protected Spliterator<P_IN> spliterator;
137 Spliterator<P_IN> spliterator) { in AbstractTask()
152 Spliterator<P_IN> spliterator) { in AbstractTask()
168 protected abstract K makeChild(Spliterator<P_IN> spliterator); in makeChild()
292 Spliterator<P_IN> rs = spliterator, ls; // right, left spliterators in compute()
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> {
69 Spliterator<P_IN> spliterator) { in AbstractShortCircuitTask()
82 Spliterator<P_IN> spliterator) { in AbstractShortCircuitTask()
102 Spliterator<P_IN> rs = spliterator, ls; in compute()
DMatchOps.java278 private static final class MatchTask<P_IN, P_OUT>
279 extends AbstractShortCircuitTask<P_IN, P_OUT, Boolean, MatchTask<P_IN, P_OUT>> {
286 Spliterator<P_IN> spliterator) { in MatchTask()
294 MatchTask(MatchTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator) { in MatchTask() argument
300 protected MatchTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) { in makeChild()
DStreamSpliterators.java60 private static abstract class AbstractWrappingSpliterator<P_IN, P_OUT,
78 private Supplier<Spliterator<P_IN>> spliteratorSupplier;
84 Spliterator<P_IN> spliterator;
90 Sink<P_IN> bufferSink;
116 Supplier<Spliterator<P_IN>> spliteratorSupplier, in AbstractWrappingSpliterator()
129 Spliterator<P_IN> spliterator, in AbstractWrappingSpliterator()
179 abstract AbstractWrappingSpliterator<P_IN, P_OUT, ?> wrap(Spliterator<P_IN> s);
192 Spliterator<P_IN> split = spliterator.trySplit();
269 static final class WrappingSpliterator<P_IN, P_OUT>
270 extends AbstractWrappingSpliterator<P_IN, P_OUT, SpinedBuffer<P_OUT>> {
[all …]
DDistinctOps.java58 <P_IN> Node<T> reduce(PipelineHelper<T> helper, Spliterator<P_IN> spliterator) { in makeRef()
69 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in makeRef()
70 Spliterator<P_IN> spliterator, in makeRef()
105 …public <P_IN> Spliterator<T> opEvaluateParallelLazy(PipelineHelper<T> helper, Spliterator<P_IN> sp… in makeRef()
DReduceOps.java706 public <P_IN> R evaluateSequential(PipelineHelper<T> helper,
707 Spliterator<P_IN> spliterator) {
712 public <P_IN> R evaluateParallel(PipelineHelper<T> helper,
713 Spliterator<P_IN> spliterator) {
722 private static final class ReduceTask<P_IN, P_OUT, R,
724 extends AbstractTask<P_IN, P_OUT, S, ReduceTask<P_IN, P_OUT, R, S>> {
729 Spliterator<P_IN> spliterator) {
734 ReduceTask(ReduceTask<P_IN, P_OUT, R, S> parent,
735 Spliterator<P_IN> spliterator) {
741 protected ReduceTask<P_IN, P_OUT, R, S> makeChild(Spliterator<P_IN> spliterator) {
DReferencePipeline.java59 public abstract class ReferencePipeline<P_IN, P_OUT>
60 extends AbstractPipeline<P_IN, P_OUT, Stream<P_OUT>>
95 ReferencePipeline(AbstractPipeline<?, P_IN, ?> upstream, int opFlags) { in ReferencePipeline() argument
109 public final <P_IN> Node<P_OUT> evaluateToNode(PipelineHelper<P_OUT> helper, in evaluateToNode()
110 Spliterator<P_IN> spliterator, in evaluateToNode()
118 public final <P_IN> Spliterator<P_OUT> wrap(PipelineHelper<P_OUT> ph, in wrap()
119 Supplier<Spliterator<P_IN>> supplier, in wrap()
690 public abstract <P_IN> Node<E_OUT> opEvaluateParallel(PipelineHelper<E_OUT> helper,
691 Spliterator<P_IN> spliterator,
DSortedOps.java147 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in opEvaluateParallel()
148 Spliterator<P_IN> spliterator, in opEvaluateParallel()
186 public <P_IN> Node<Integer> opEvaluateParallel(PipelineHelper<Integer> helper, in opEvaluateParallel()
187 Spliterator<P_IN> spliterator, in opEvaluateParallel()
225 public <P_IN> Node<Long> opEvaluateParallel(PipelineHelper<Long> helper, in opEvaluateParallel()
226 Spliterator<P_IN> spliterator, in opEvaluateParallel()
264 public <P_IN> Node<Double> opEvaluateParallel(PipelineHelper<Double> helper, in opEvaluateParallel()
265 Spliterator<P_IN> spliterator, in opEvaluateParallel()
DIntPipeline.java142 public final <P_IN> Node<Integer> evaluateToNode(PipelineHelper<Integer> helper, in evaluateToNode()
143 Spliterator<P_IN> spliterator, in evaluateToNode()
151 public final <P_IN> Spliterator<Integer> wrap(PipelineHelper<Integer> ph, in wrap()
152 Supplier<Spliterator<P_IN>> supplier, in wrap()
661 public abstract <P_IN> Node<Integer> opEvaluateParallel(PipelineHelper<Integer> helper,
662 Spliterator<P_IN> spliterator,
DLongPipeline.java140 public final <P_IN> Node<Long> evaluateToNode(PipelineHelper<Long> helper, in evaluateToNode()
141 Spliterator<P_IN> spliterator, in evaluateToNode()
149 public final <P_IN> Spliterator<Long> wrap(PipelineHelper<Long> ph, in wrap()
150 Supplier<Spliterator<P_IN>> supplier, in wrap()
642 public abstract <P_IN> Node<Long> opEvaluateParallel(PipelineHelper<Long> helper,
643 Spliterator<P_IN> spliterator,
DDoublePipeline.java139 public final <P_IN> Node<Double> evaluateToNode(PipelineHelper<Double> helper, in evaluateToNode()
140 Spliterator<P_IN> spliterator, in evaluateToNode()
148 public final <P_IN> Spliterator<Double> wrap(PipelineHelper<Double> ph, in wrap()
149 Supplier<Spliterator<P_IN>> supplier, in wrap()
666 public abstract <P_IN> Node<Double> opEvaluateParallel(PipelineHelper<Double> helper,
667 Spliterator<P_IN> spliterator,
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatefulTestOp.java46 public <P_IN> Spliterator<T> opEvaluateParallelLazy(PipelineHelper<T> helper, in chain()
47 Spliterator<P_IN> spliterator) { in chain()
52 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in chain()
53 Spliterator<P_IN> spliterator, in chain()
66 … public <P_IN> Spliterator<Integer> opEvaluateParallelLazy(PipelineHelper<Integer> helper, in chain()
67 Spliterator<P_IN> spliterator) { in chain()
72 public <P_IN> Node<Integer> opEvaluateParallel(PipelineHelper<Integer> helper, in chain()
73 Spliterator<P_IN> spliterator, in chain()
86 <P_IN> Spliterator<Long> opEvaluateParallelLazy(PipelineHelper<Long> helper, in chain()
87 Spliterator<P_IN> spliterator) { in chain()
[all …]
DCollectorOps.java70 public <P_IN> Node<E_IN> opEvaluateParallel(PipelineHelper<E_IN> helper, in opEvaluateParallel()
71 Spliterator<P_IN> spliterator, in opEvaluateParallel()
87 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in opEvaluateParallel()
88 Spliterator<P_IN> spliterator, in opEvaluateParallel()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatefulTestOp.java45 public <P_IN> Spliterator<T> opEvaluateParallelLazy(PipelineHelper<T> helper, in chain()
46 Spliterator<P_IN> spliterator) { in chain()
51 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in chain()
52 Spliterator<P_IN> spliterator, in chain()
65 … public <P_IN> Spliterator<Integer> opEvaluateParallelLazy(PipelineHelper<Integer> helper, in chain()
66 Spliterator<P_IN> spliterator) { in chain()
71 public <P_IN> Node<Integer> opEvaluateParallel(PipelineHelper<Integer> helper, in chain()
72 Spliterator<P_IN> spliterator, in chain()
85 … public <P_IN> Spliterator<Long> opEvaluateParallelLazy(PipelineHelper<Long> helper, in chain()
86 Spliterator<P_IN> spliterator) { in chain()
[all …]
DCollectorOps.java69 public <P_IN> Node<E_IN> opEvaluateParallel(PipelineHelper<E_IN> helper, in opEvaluateParallel()
70 Spliterator<P_IN> spliterator, in opEvaluateParallel()
86 public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, in opEvaluateParallel()
87 Spliterator<P_IN> spliterator, in opEvaluateParallel()