/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
D | StatefulTestOp.java | 35 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 …]
|
D | StatelessTestOp.java | 32 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 …]
|
D | IntermediateTestOp.java | 32 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()
|
D | OpTestCase.java | 617 …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/ |
D | StatefulTestOp.java | 36 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 …]
|
D | StatelessTestOp.java | 40 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 …]
|
D | IntermediateTestOp.java | 34 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()
|
D | OpTestCase.java | 618 …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/ |
D | FindOps.java | 252 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()
|
D | MatchOps.java | 280 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()
|
D | SliceOps.java | 561 private final AbstractPipeline<P_OUT, P_OUT, ?> op; 568 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op, 574 this.op = op; 582 this.op = parent.op; 595 return Nodes.emptyNode(op.getOutputShape()); 601 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags) 602 ? op.exactOutputSizeIfKnown(spliterator) 604 final Node.Builder<P_OUT> nb = op.makeNodeBuilder(sizeIfKnown, generator); 605 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb); 635 result = Nodes.conc(op.getOutputShape(),
|
D | Collectors.java | 657 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 …]
|
D | ReduceOps.java | 725 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);
|
D | DoubleStream.java | 375 double reduce(double identity, DoubleBinaryOperator op); in reduce() argument 412 OptionalDouble reduce(DoubleBinaryOperator op); in reduce() argument
|
D | IntStream.java | 370 int reduce(int identity, IntBinaryOperator op); in reduce() argument 407 OptionalInt reduce(IntBinaryOperator op); in reduce() argument
|
D | DoublePipeline.java | 460 public final double reduce(double identity, DoubleBinaryOperator op) { 461 return evaluate(ReduceOps.makeDouble(identity, op)); 465 public final OptionalDouble reduce(DoubleBinaryOperator op) { 466 return evaluate(ReduceOps.makeDouble(op));
|
D | LongPipeline.java | 438 public final long reduce(long identity, LongBinaryOperator op) { 439 return evaluate(ReduceOps.makeLong(identity, op)); 443 public final OptionalLong reduce(LongBinaryOperator op) { 444 return evaluate(ReduceOps.makeLong(op));
|
D | IntPipeline.java | 456 public final int reduce(int identity, IntBinaryOperator op) { 457 return evaluate(ReduceOps.makeInt(identity, op)); 461 public final OptionalInt reduce(IntBinaryOperator op) { 462 return evaluate(ReduceOps.makeInt(op));
|
D | LongStream.java | 374 long reduce(long identity, LongBinaryOperator op); in reduce() argument 411 OptionalLong reduce(LongBinaryOperator op); in reduce() argument
|
/libcore/ojluni/src/main/java/java/util/ |
D | Arrays.java | 1620 public static <T> void parallelPrefix(T[] array, BinaryOperator<T> op) { in parallelPrefix() argument 1621 Objects.requireNonNull(op); in parallelPrefix() 1624 (null, op, array, 0, array.length).invoke(); in parallelPrefix() 1644 int toIndex, BinaryOperator<T> op) { in parallelPrefix() argument 1645 Objects.requireNonNull(op); in parallelPrefix() 1649 (null, op, array, fromIndex, toIndex).invoke(); in parallelPrefix() 1666 public static void parallelPrefix(long[] array, LongBinaryOperator op) { in parallelPrefix() argument 1667 Objects.requireNonNull(op); in parallelPrefix() 1670 (null, op, array, 0, array.length).invoke(); in parallelPrefix() 1689 int toIndex, LongBinaryOperator op) { in parallelPrefix() argument [all …]
|
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
D | TabulatorsTest.java | 406 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/luni/src/main/java/libcore/io/ |
D | IoBridge.java | 393 int op = (option == JAVA_MCAST_JOIN_GROUP) ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP; in setSocketOptionErrno() local 394 Libcore.os.setsockoptGroupReq(fd, level, op, groupReq); in setSocketOptionErrno() 405 int op = getGroupSourceReqOp(option); in setSocketOptionErrno() local 406 Libcore.os.setsockoptGroupSourceReq(fd, level, op, groupSourceReq); in setSocketOptionErrno()
|
/libcore/ojluni/src/main/java/java/net/ |
D | DatagramSocket.java | 398 void checkAddress (InetAddress addr, String op) { in checkAddress() argument 403 throw new IllegalArgumentException(op + ": invalid address type"); in checkAddress()
|
D | Socket.java | 638 private void checkAddress (InetAddress addr, String op) { in checkAddress() argument 643 throw new IllegalArgumentException(op + ": invalid address type"); in checkAddress()
|