/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
H A D | IntermediateTestOp.java | 32 IntermediateTestOp<?, T> op) { 33 if (op instanceof StatelessTestOp) 34 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); 36 if (op instanceof StatefulTestOp) 37 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); 39 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); 31 chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) argument
|
H A D | StatelessTestOp.java | 32 StatelessTestOp<?, T> op) { 33 int flags = op.opGetFlags(); 34 switch (op.outputShape()) { 36 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { 38 return op.opWrapSink(flags, isParallel(), sink); 42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 44 return op.opWrapSink(flags, isParallel(), sink); 48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 51 return op.opWrapSink(flags, isParallel(), sink); 55 return new DoublePipeline.StatelessOp<Object>(upstream, op 31 chain(AbstractPipeline upstream, StatelessTestOp<?, T> op) argument [all...] |
H A D | StatefulTestOp.java | 35 StatefulTestOp op) { 36 switch (op.outputShape()) { 38 return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { 41 return op.opWrapSink(flags, isParallel(), sink); 47 return op.opEvaluateParallelLazy(helper, spliterator); 54 return op.opEvaluateParallel(helper, spliterator, generator); 58 return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 61 return op 34 chain(AbstractPipeline upstream, StatefulTestOp op) argument [all...] |
H A D | OpTestCase.java | 550 // Sequentially collect the output that will be input to the terminal op 617 private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { argument 618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); 623 for (IntermediateTestOp op : ops) 624 pipe = chain(pipe, op); 629 private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { argument 630 return chain((AbstractPipeline) pipe, op);
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
H A D | IntermediateTestOp.java | 34 IntermediateTestOp<?, T> op) { 35 if (op instanceof StatelessTestOp) 36 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); 38 if (op instanceof StatefulTestOp) 39 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); 41 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); 33 chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) argument
|
H A D | StatelessTestOp.java | 40 StatelessTestOp<?, T> op) { 41 int flags = op.opGetFlags(); 42 switch (op.outputShape()) { 44 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { 47 return op.opWrapSink(flags, isParallel(), sink); 51 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 54 return op.opWrapSink(flags, isParallel(), sink); 58 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 61 return op.opWrapSink(flags, isParallel(), sink); 65 return new DoublePipeline.StatelessOp<Object>(upstream, op 39 chain(AbstractPipeline upstream, StatelessTestOp<?, T> op) argument [all...] |
H A D | StatefulTestOp.java | 36 StatefulTestOp op) { 37 switch (op.outputShape()) { 39 return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { 42 return op.opWrapSink(flags, isParallel(), sink); 48 return op.opEvaluateParallelLazy(helper, spliterator); 55 return op.opEvaluateParallel(helper, spliterator, generator); 59 return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { 62 return op 35 chain(AbstractPipeline upstream, StatefulTestOp op) argument [all...] |
H A D | OpTestCase.java | 551 // Sequentially collect the output that will be input to the terminal op 618 private static <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { argument 619 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); 624 for (IntermediateTestOp op : ops) 625 pipe = chain(pipe, op); 630 private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { argument 631 return chain((AbstractPipeline) pipe, op);
|
/libcore/ojluni/src/main/java/java/util/stream/ |
H A D | FindOps.java | 252 private final FindOp<P_OUT, O> op; field in class:FindOps.FindTask 254 FindTask(FindOp<P_OUT, O> op, argument 258 this.op = op; 263 this.op = parent.op; 273 return op.emptyValue; 285 O result = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).get(); 286 if (!op.mustFindFirst) { 303 if (op [all...] |
H A D | MatchOps.java | 280 private final MatchOp<P_OUT> op; field in class:MatchOps.MatchTask 285 MatchTask(MatchOp<P_OUT> op, PipelineHelper<P_OUT> helper, argument 288 this.op = op; 296 this.op = parent.op; 306 boolean b = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).getAndClearState(); 307 if (b == op.matchKind.shortCircuitResult) 314 return !op.matchKind.shortCircuitResult;
|
H A D | SliceOps.java | 561 private final AbstractPipeline<P_OUT, P_OUT, ?> op; field in class:SliceOps.SliceTask 568 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op, argument 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 [all...] |
H A D | DoubleStream.java | 365 * @param op an <a href="package-summary.html#Associativity">associative</a>, 375 double reduce(double identity, DoubleBinaryOperator op); argument 405 * @param op an <a href="package-summary.html#Associativity">associative</a>, 412 OptionalDouble reduce(DoubleBinaryOperator op); argument
|
H A D | Collectors.java | 650 * @param op a {@code BinaryOperator<T>} used to reduce the input elements 657 reducing(T identity, BinaryOperator<T> op) { argument 660 (a, t) -> { a[0] = op.apply(a[0], t); }, 661 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; }, 691 * @param op a {@code BinaryOperator<T>} used to reduce the input elements 698 reducing(BinaryOperator<T> op) { argument 706 value = op.apply(value, t); 749 * @param op a {@code BinaryOperator<U>} used to reduce the mapped values 758 BinaryOperator<U> op) { 761 (a, t) -> { a[0] = op 756 reducing(U identity, Function<? super T, ? extends U> mapper, BinaryOperator<U> op) argument [all...] |
H A D | ReduceOps.java | 725 private final ReduceOp<P_OUT, R, S> op; field in class:ReduceOps.ReduceTask 727 ReduceTask(ReduceOp<P_OUT, R, S> op, argument 731 this.op = op; 737 this.op = parent.op; 747 return helper.wrapAndCopyInto(op.makeSink(), spliterator);
|
H A D | DoublePipeline.java | 460 public final double reduce(double identity, DoubleBinaryOperator op) { argument 461 return evaluate(ReduceOps.makeDouble(identity, op)); 465 public final OptionalDouble reduce(DoubleBinaryOperator op) { argument 466 return evaluate(ReduceOps.makeDouble(op));
|
H A D | LongPipeline.java | 438 public final long reduce(long identity, LongBinaryOperator op) { argument 439 return evaluate(ReduceOps.makeLong(identity, op)); 443 public final OptionalLong reduce(LongBinaryOperator op) { argument 444 return evaluate(ReduceOps.makeLong(op));
|
H A D | IntStream.java | 360 * @param op an <a href="package-summary.html#Associativity">associative</a>, 370 int reduce(int identity, IntBinaryOperator op); argument 400 * @param op an <a href="package-summary.html#Associativity">associative</a>, 407 OptionalInt reduce(IntBinaryOperator op); argument
|
H A D | LongStream.java | 364 * @param op an <a href="package-summary.html#Associativity">associative</a>, 374 long reduce(long identity, LongBinaryOperator op); argument 404 * @param op an <a href="package-summary.html#Associativity">associative</a>, 411 OptionalLong reduce(LongBinaryOperator op); argument
|
H A D | IntPipeline.java | 456 public final int reduce(int identity, IntBinaryOperator op) { argument 457 return evaluate(ReduceOps.makeInt(identity, op)); 461 public final OptionalInt reduce(IntBinaryOperator op) { argument 462 return evaluate(ReduceOps.makeInt(op));
|
/libcore/luni/src/test/java/libcore/java/net/ |
H A D | SocketTimeoutTest.java | 60 SocketOperation<T> op) throws Exception { 64 op.operate(socket); 59 checkOperationTimesOut(SocketConstructor<T> construct, SocketOperation<T> op) argument
|
/libcore/ojluni/src/main/java/java/util/ |
H A D | Arrays.java | 1514 * @param op a side-effect-free, associative function to perform the 1519 public static <T> void parallelPrefix(T[] array, BinaryOperator<T> op) { argument 1520 Objects.requireNonNull(op); 1523 (null, op, array, 0, array.length).invoke(); 1534 * @param op a side-effect-free, associative function to perform the 1543 int toIndex, BinaryOperator<T> op) { 1544 Objects.requireNonNull(op); 1548 (null, op, array, fromIndex, toIndex).invoke(); 1560 * @param op a side-effect-free, associative function to perform the 1565 public static void parallelPrefix(long[] array, LongBinaryOperator op) { argument 1542 parallelPrefix(T[] array, int fromIndex, int toIndex, BinaryOperator<T> op) argument 1587 parallelPrefix(long[] array, int fromIndex, int toIndex, LongBinaryOperator op) argument 1613 parallelPrefix(double[] array, DoubleBinaryOperator op) argument 1635 parallelPrefix(double[] array, int fromIndex, int toIndex, DoubleBinaryOperator op) argument 1658 parallelPrefix(int[] array, IntBinaryOperator op) argument 1680 parallelPrefix(int[] array, int fromIndex, int toIndex, IntBinaryOperator op) argument [all...] |
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A 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/ojluni/src/main/java/java/net/ |
H A D | DatagramSocket.java | 419 void checkAddress (InetAddress addr, String op) { argument 424 throw new IllegalArgumentException(op + ": invalid address type"); 1316 * Passing {@code null} to the method is a no-op unless the factory
|
H A D | Socket.java | 675 private void checkAddress (InetAddress addr, String op) { argument 680 throw new IllegalArgumentException(op + ": invalid address type"); 1697 * Passing {@code null} to the method is a no-op unless the factory
|
/libcore/luni/src/main/java/libcore/io/ |
H A D | IoBridge.java | 230 * <p>This method is a no-op if passed a {@code null} or already-closed file descriptor. 450 int op = (option == JAVA_MCAST_JOIN_GROUP) ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP; 451 Libcore.os.setsockoptGroupReq(fd, level, op, groupReq); 462 int op = getGroupSourceReqOp(option); 463 Libcore.os.setsockoptGroupSourceReq(fd, level, op, groupSourceReq); 483 "Unknown java value for setsocketopt op lookup: " + javaValue);
|