Home
last modified time | relevance | path

Searched refs:op (Results 1 – 25 of 29) 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()
DOpTestCase.java618 …tatic <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { in chain() argument
619 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
624 for (IntermediateTestOp op : ops) in chain()
625 pipe = chain(pipe, op); in chain()
630 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
631 return chain((AbstractPipeline) pipe, op); in chain()
/libcore/ojluni/src/main/java/java/util/stream/
DFindOps.java252 private final FindOp<P_OUT, O> op; field in FindOps.FindTask
254 FindTask(FindOp<P_OUT, O> op, in FindTask() argument
258 this.op = op; in FindTask()
263 this.op = parent.op; in FindTask()
273 return op.emptyValue; in getEmptyResult()
285 O result = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).get(); in doLeaf()
286 if (!op.mustFindFirst) { in doLeaf()
303 if (op.mustFindFirst) { in onCompletion()
307 if (result != null && op.presentPredicate.test(result)) { in onCompletion()
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()
DSliceOps.java573 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
580 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
586 this.op = op;
594 this.op = parent.op;
607 return Nodes.emptyNode(op.getOutputShape());
613 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags)
614 ? op.exactOutputSizeIfKnown(spliterator)
616 final Node.Builder<P_OUT> nb = op.makeNodeBuilder(sizeIfKnown, generator);
617 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
647 result = Nodes.conc(op.getOutputShape(),
DCollectors.java657 reducing(T identity, BinaryOperator<T> op) {
660 (a, t) -> { a[0] = op.apply(a[0], t); },
661 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
698 reducing(BinaryOperator<T> op) {
706 value = op.apply(value, t);
758 BinaryOperator<U> op) {
761 (a, t) -> { a[0] = op.apply(a[0], mapper.apply(t)); },
762 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
1140 BinaryOperator<A> op = downstream.combiner();
1142 new Partition<>(op.apply(left.forTrue, right.forTrue),
[all …]
DReduceOps.java725 private final ReduceOp<P_OUT, R, S> op;
727 ReduceTask(ReduceOp<P_OUT, R, S> op,
731 this.op = op;
737 this.op = parent.op;
747 return helper.wrapAndCopyInto(op.makeSink(), spliterator);
DDoubleStream.java377 double reduce(double identity, DoubleBinaryOperator op); in reduce() argument
414 OptionalDouble reduce(DoubleBinaryOperator op); in reduce() argument
DIntStream.java370 int reduce(int identity, IntBinaryOperator op); in reduce() argument
407 OptionalInt reduce(IntBinaryOperator op); in reduce() argument
DIntPipeline.java472 public final int reduce(int identity, IntBinaryOperator op) {
473 return evaluate(ReduceOps.makeInt(identity, op));
477 public final OptionalInt reduce(IntBinaryOperator op) {
478 return evaluate(ReduceOps.makeInt(op));
DDoublePipeline.java475 public final double reduce(double identity, DoubleBinaryOperator op) {
476 return evaluate(ReduceOps.makeDouble(identity, op));
480 public final OptionalDouble reduce(DoubleBinaryOperator op) {
481 return evaluate(ReduceOps.makeDouble(op));
DLongPipeline.java454 public final long reduce(long identity, LongBinaryOperator op) {
455 return evaluate(ReduceOps.makeLong(identity, op));
459 public final OptionalLong reduce(LongBinaryOperator op) {
460 return evaluate(ReduceOps.makeLong(op));
DLongStream.java375 long reduce(long identity, LongBinaryOperator op); in reduce() argument
412 OptionalLong reduce(LongBinaryOperator 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/ojluni/src/main/java/java/util/
DArrays.java1516 public static <T> void parallelPrefix(T[] array, BinaryOperator<T> op) { in parallelPrefix() argument
1517 Objects.requireNonNull(op); in parallelPrefix()
1520 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1540 int toIndex, BinaryOperator<T> op) { in parallelPrefix() argument
1541 Objects.requireNonNull(op); in parallelPrefix()
1545 (null, op, array, fromIndex, toIndex).invoke(); in parallelPrefix()
1562 public static void parallelPrefix(long[] array, LongBinaryOperator op) { in parallelPrefix() argument
1563 Objects.requireNonNull(op); in parallelPrefix()
1566 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1585 int toIndex, LongBinaryOperator op) { in parallelPrefix() argument
[all …]
/libcore/luni/src/test/java/libcore/java/net/
DSocketTimeoutTest.java60 SocketOperation<T> op) throws Exception { in checkOperationTimesOut() argument
64 op.operate(socket); in checkOperationTimesOut()
/libcore/ojluni/annotations/sdk/nullability/java/util/
DArrays.annotated.java118 …nNull java.util.function.BinaryOperator<@libcore.util.NullFromTypeParam T> op) { throw new Runtime… in parallelPrefix() argument
120 …nNull java.util.function.BinaryOperator<@libcore.util.NullFromTypeParam T> op) { throw new Runtime… in parallelPrefix() argument
122 …Null [] array, @libcore.util.NonNull java.util.function.LongBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
124 …, int toIndex, @libcore.util.NonNull java.util.function.LongBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
126 …ll [] array, @libcore.util.NonNull java.util.function.DoubleBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
128 …int toIndex, @libcore.util.NonNull java.util.function.DoubleBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
130 …nNull [] array, @libcore.util.NonNull java.util.function.IntBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
132 …x, int toIndex, @libcore.util.NonNull java.util.function.IntBinaryOperator op) { throw new Runtime… in parallelPrefix() argument
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DTabulatorsTest.java406 for (BinaryOperator<Integer> op : Arrays.asList((u, v) -> u,
411 new ToMapAssertion<>(keyFn, valueFn, op, HashMap.class));
420 exerciseMapTabulation(data, toMap(keyFn, valueFn, op),
421 new ToMapAssertion<>(keyFn, valueFn, op, HashMap.class));
423 exerciseMapTabulation(data, toMap(keyFn, valueFn, op, TreeMap::new),
424 new ToMapAssertion<>(keyFn, valueFn, op, TreeMap.class));
/libcore/ojluni/annotations/hiddenapi/java/net/
DDatagramSocket.java75 void checkAddress(java.net.InetAddress addr, java.lang.String op) { in checkAddress() argument

12