Home
last modified time | relevance | path

Searched refs:op (Results 1 – 25 of 38) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatefulTestOp.java35 StatefulTestOp op) { in chain() argument
36 switch (op.outputShape()) { in chain()
38 … return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
41 return op.opWrapSink(flags, isParallel(), sink); in chain()
47 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
54 return op.opEvaluateParallel(helper, spliterator, generator); in chain()
58 … return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
67 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
74 … return (Node<Integer>) op.opEvaluateParallel(helper, spliterator, generator); in chain()
[all …]
DStatelessTestOp.java32 StatelessTestOp<?, T> op) { in chain() argument
33 int flags = op.opGetFlags(); in chain()
34 switch (op.outputShape()) { in chain()
36 … return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { in chain()
38 return op.opWrapSink(flags, isParallel(), sink); in chain()
42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
44 return op.opWrapSink(flags, isParallel(), sink); in chain()
48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
51 return op.opWrapSink(flags, isParallel(), sink); in chain()
55 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
[all …]
DIntermediateTestOp.java32 IntermediateTestOp<?, T> op) { in chain() argument
33 if (op instanceof StatelessTestOp) in chain()
34 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); in chain()
36 if (op instanceof StatefulTestOp) in chain()
37 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); in chain()
39 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); in chain()
DOpTestCase.java617 …tatic <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { in chain() argument
618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
623 for (IntermediateTestOp op : ops) in chain()
624 pipe = chain(pipe, op); in chain()
629 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
630 return chain((AbstractPipeline) pipe, op); in chain()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatefulTestOp.java36 StatefulTestOp op) { in chain() argument
37 switch (op.outputShape()) { in chain()
39 … return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
42 return op.opWrapSink(flags, isParallel(), sink); in chain()
48 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
55 return op.opEvaluateParallel(helper, spliterator, generator); in chain()
59 … return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
62 return op.opWrapSink(flags, isParallel(), sink); in chain()
68 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
75 … return (Node<Integer>) op.opEvaluateParallel(helper, spliterator, generator); in chain()
[all …]
DStatelessTestOp.java40 StatelessTestOp<?, T> op) { in chain() argument
41 int flags = op.opGetFlags(); in chain()
42 switch (op.outputShape()) { in chain()
44 … return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { in chain()
47 return op.opWrapSink(flags, isParallel(), sink); in chain()
51 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
54 return op.opWrapSink(flags, isParallel(), sink); in chain()
58 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
65 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
[all …]
DIntermediateTestOp.java34 IntermediateTestOp<?, T> op) { in chain() argument
35 if (op instanceof StatelessTestOp) in chain()
36 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); in chain()
38 if (op instanceof StatefulTestOp) in chain()
39 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); in chain()
41 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); in chain()
DDefaultMethodStreams.java468 public int reduce(int identity, IntBinaryOperator op) { in reduce() argument
469 return s.reduce(identity, op); in reduce()
473 public OptionalInt reduce(IntBinaryOperator op) { in reduce() argument
474 return s.reduce(op); in reduce()
674 public long reduce(long identity, LongBinaryOperator op) { in reduce() argument
675 return s.reduce(identity, op); in reduce()
679 public OptionalLong reduce(LongBinaryOperator op) { in reduce() argument
680 return s.reduce(op); in reduce()
872 public double reduce(double identity, DoubleBinaryOperator op) { in reduce() argument
873 return s.reduce(identity, op); in reduce()
[all …]
/libcore/ojluni/src/main/java/java/util/stream/
DMatchOps.java280 private final MatchOp<P_OUT> op; field in MatchOps.MatchTask
285 MatchTask(MatchOp<P_OUT> op, PipelineHelper<P_OUT> helper, in MatchTask() argument
288 this.op = op; in MatchTask()
296 this.op = parent.op; in MatchTask()
306 … boolean b = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).getAndClearState(); in doLeaf()
307 if (b == op.matchKind.shortCircuitResult) in doLeaf()
314 return !op.matchKind.shortCircuitResult; in getEmptyResult()
DFindOps.java282 private final FindOp<P_OUT, O> op; field in FindOps.FindTask
285 FindTask(FindOp<P_OUT, O> op, in FindTask() argument
291 this.op = op; in FindTask()
297 this.op = parent.op; in FindTask()
307 return op.emptyValue; in getEmptyResult()
319 O result = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).get(); in doLeaf()
341 if (result != null && op.presentPredicate.test(result)) { in onCompletion()
DSliceOps.java587 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
594 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
600 this.op = op;
608 this.op = parent.op;
621 return Nodes.emptyNode(op.getOutputShape());
627 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags)
628 ? op.exactOutputSizeIfKnown(spliterator)
630 final Node.Builder<P_OUT> nb = op.makeNodeBuilder(sizeIfKnown, generator);
631 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
638 final Node.Builder<P_OUT> nb = op.makeNodeBuilder(-1, generator);
[all …]
DWhileOps.java1191 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
1200 TakeWhileTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
1205 this.op = op;
1212 this.op = parent.op;
1224 return Nodes.emptyNode(op.getOutputShape());
1230 Sink<P_OUT> s = op.opWrapSink(helper.getStreamAndOpFlags(), builder);
1283 return Nodes.conc(op.getOutputShape(),
1321 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
1330 DropWhileTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
1335 assert op instanceof DropWhileOp;
[all …]
DCollectors.java883 reducing(T identity, BinaryOperator<T> op) {
886 (a, t) -> { a[0] = op.apply(a[0], t); },
887 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
926 reducing(BinaryOperator<T> op) {
934 value = op.apply(value, t);
989 BinaryOperator<U> op) {
992 (a, t) -> { a[0] = op.apply(a[0], mapper.apply(t)); },
993 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
1398 BinaryOperator<A> op = downstream.combiner();
1400 new Partition<>(op.apply(left.forTrue, right.forTrue),
[all …]
DReduceOps.java938 private final ReduceOp<P_OUT, R, S> op;
940 ReduceTask(ReduceOp<P_OUT, R, S> op,
944 this.op = op;
950 this.op = parent.op;
960 return helper.wrapAndCopyInto(op.makeSink(), spliterator);
DIntPipeline.java532 public final int reduce(int identity, IntBinaryOperator op) {
533 return evaluate(ReduceOps.makeInt(identity, op));
537 public final OptionalInt reduce(IntBinaryOperator op) {
538 return evaluate(ReduceOps.makeInt(op));
DLongPipeline.java515 public final long reduce(long identity, LongBinaryOperator op) {
516 return evaluate(ReduceOps.makeLong(identity, op));
520 public final OptionalLong reduce(LongBinaryOperator op) {
521 return evaluate(ReduceOps.makeLong(op));
DDoublePipeline.java540 public final double reduce(double identity, DoubleBinaryOperator op) {
541 return evaluate(ReduceOps.makeDouble(identity, op));
545 public final OptionalDouble reduce(DoubleBinaryOperator op) {
546 return evaluate(ReduceOps.makeDouble(op));
DDoubleStream.java547 double reduce(double identity, DoubleBinaryOperator op); in reduce() argument
584 OptionalDouble reduce(DoubleBinaryOperator op); in reduce() argument
/libcore/ojluni/annotations/hiddenapi/java/util/
DArrays.java198 public static <T> void parallelPrefix(T[] array, java.util.function.BinaryOperator<T> op) { in parallelPrefix() argument
203 T[] array, int fromIndex, int toIndex, java.util.function.BinaryOperator<T> op) { in parallelPrefix() argument
207 public static void parallelPrefix(long[] array, java.util.function.LongBinaryOperator op) { in parallelPrefix() argument
212 long[] array, int fromIndex, int toIndex, java.util.function.LongBinaryOperator op) { in parallelPrefix() argument
216 public static void parallelPrefix(double[] array, java.util.function.DoubleBinaryOperator op) { in parallelPrefix() argument
224 java.util.function.DoubleBinaryOperator op) { in parallelPrefix() argument
228 public static void parallelPrefix(int[] array, java.util.function.IntBinaryOperator op) { in parallelPrefix() argument
233 int[] array, int fromIndex, int toIndex, java.util.function.IntBinaryOperator op) { in parallelPrefix() argument
/libcore/luni/src/test/java/libcore/java/net/
DSocketTimeoutTest.java61 SocketOperation<T> op) throws Exception { in checkOperationTimesOut() argument
65 op.operate(socket); in checkOperationTimesOut()
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DWhileOpTest.java190 WhileOp op, in whileResultAsserter() argument
200 if (op == WhileOp.Take) { in whileResultAsserter()
226 else if (op == WhileOp.Drop) { in whileResultAsserter()
258 if (op == WhileOp.Take) { in whileResultAsserter()
269 else if (op == WhileOp.Drop) { in whileResultAsserter()
/libcore/ojluni/src/main/java/java/util/
DArrays.java1434 public static <T> void parallelPrefix(T[] array, BinaryOperator<T> op) { in parallelPrefix() argument
1435 Objects.requireNonNull(op); in parallelPrefix()
1438 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1458 int toIndex, BinaryOperator<T> op) { in parallelPrefix() argument
1459 Objects.requireNonNull(op); in parallelPrefix()
1463 (null, op, array, fromIndex, toIndex).invoke(); in parallelPrefix()
1480 public static void parallelPrefix(long[] array, LongBinaryOperator op) { in parallelPrefix() argument
1481 Objects.requireNonNull(op); in parallelPrefix()
1484 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1503 int toIndex, LongBinaryOperator op) { in parallelPrefix() argument
[all …]
/libcore/ojluni/annotations/flagged_api/java/util/stream/
DDoubleStream.annotated.java68 public double reduce(double identity, java.util.function.DoubleBinaryOperator op); in reduce() argument
70 public java.util.OptionalDouble reduce(java.util.function.DoubleBinaryOperator op); in reduce() argument
DIntStream.annotated.java68 public int reduce(int identity, java.util.function.IntBinaryOperator op); in reduce() argument
70 public java.util.OptionalInt reduce(java.util.function.IntBinaryOperator op); in reduce() argument
DLongStream.annotated.java68 public long reduce(long identity, java.util.function.LongBinaryOperator op); in reduce() argument
70 public java.util.OptionalLong reduce(java.util.function.LongBinaryOperator op); in reduce() argument

12