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

/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DIntermediateTestOp.java32 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 DStatelessTestOp.java32 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 DStatefulTestOp.java35 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 DOpTestCase.java550 // 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 DIntermediateTestOp.java34 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 DStatelessTestOp.java40 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 DStatefulTestOp.java36 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 DOpTestCase.java551 // 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 DFindOps.java252 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 DMatchOps.java280 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 DSliceOps.java561 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 DDoubleStream.java365 * @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 DCollectors.java650 * @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 DReduceOps.java725 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 DDoublePipeline.java460 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 DLongPipeline.java438 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 DIntStream.java360 * @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 DLongStream.java364 * @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 DIntPipeline.java456 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 DSocketTimeoutTest.java60 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 DArrays.java1514 * @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 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/src/main/java/java/net/
H A DDatagramSocket.java420 void checkAddress (InetAddress addr, String op) { argument
425 throw new IllegalArgumentException(op + ": invalid address type");
1316 * Passing {@code null} to the method is a no-op unless the factory
H A DSocket.java680 private void checkAddress (InetAddress addr, String op) { argument
685 throw new IllegalArgumentException(op + ": invalid address type");
1702 * Passing {@code null} to the method is a no-op unless the factory
/libcore/luni/src/main/java/libcore/io/
H A DIoBridge.java234 * <p>This method is a no-op if passed a {@code null} or already-closed file descriptor.
451 int op = (option == JAVA_MCAST_JOIN_GROUP) ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP;
452 Libcore.os.setsockoptGroupReq(fd, level, op, groupReq);

Completed in 290 milliseconds