| /libcore/ojluni/src/main/java/java/util/stream/ |
| H A D | ReferencePipeline.java | 491 public final <R, A> R collect(Collector<? super P_OUT, A, R> collector) { argument
494 && (collector.characteristics().contains(Collector.Characteristics.CONCURRENT))
495 && (!isOrdered() || collector.characteristics().contains(Collector.Characteristics.UNORDERED))) {
496 container = collector.supplier().get();
497 BiConsumer<A, ? super P_OUT> accumulator = collector.accumulator();
501 container = evaluate(ReduceOps.makeRef(collector));
503 return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)
505 : collector.finisher().apply(container);
|
| H A D | ReduceOps.java | 152 * @param collector a {@code Collector} defining the reduction
156 makeRef(Collector<? super T, I, ?> collector) { argument
157 Supplier<I> supplier = Objects.requireNonNull(collector).supplier();
158 BiConsumer<I, ? super T> accumulator = collector.accumulator();
159 BinaryOperator<I> combiner = collector.combiner();
185 return collector.characteristics().contains(Collector.Characteristics.UNORDERED)
|
| H A D | Stream.java | 763 * either the stream is unordered or the collector is
799 * @param collector the {@code Collector} describing the reduction
804 <R, A> R collect(Collector<? super T, A, R> collector); argument
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| H A D | CollectorOps.java | 34 public static <E_IN> StatefulTestOp<E_IN> collector() { method in class:CollectorOps
|
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| H A D | FlagOpTest.java | 160 testFlagsSetSequence(CollectorOps::collector);
194 testFlagsClearSequence(CollectorOps::collector);
234 ops.add(CollectorOps.collector());
240 ops.add(CollectorOps.collector());
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| H A D | CollectorOps.java | 35 public static <E_IN> StatefulTestOp<E_IN> collector() { method in class:CollectorOps
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| H A D | GroupByOpTest.java | 63 Collector<Integer, Map<Boolean, List<Integer>>, Map<Boolean, List<Integer>>> collector
66 Map<Boolean, List<Integer>> m = collector.supplier().get();
69 collector.accumulator().accept(m, i);
|
| H A D | TabulatorsTest.java | 247 Collector<T, ?, ? extends M> collector,
250 boolean ordered = !collector.characteristics().contains(Collector.Characteristics.UNORDERED);
253 .terminal(s -> s.collect(collector))
259 .terminal(s -> s.unordered().collect(collector))
281 Collector<T, ?, R> collector,
284 withData(data).terminal(s -> s.collect(collector)).expectedResult(check).exercise();
246 exerciseMapTabulation(TestData<T, Stream<T>> data, Collector<T, ?, ? extends M> collector, TabulationAssertion<T, M> assertion) argument
280 assertCollect(TestData.OfRef<T> data, Collector<T, ?, R> collector, Function<Stream<T>, R> streamReduction) argument
|
| /libcore/ojluni/src/main/java/java/lang/invoke/ |
| H A D | Transformers.java | 1533 private final MethodHandle collector; field in class:Transformers.CollectArguments
1536 /** The range of input arguments we copy to the collector. */
1554 CollectArguments(MethodHandle target, MethodHandle collector, int pos, argument
1559 this.collector = collector;
1562 final int numFilterArgs = collector.type().parameterCount();
1575 final Class<?> collectorRType = collector.type().rtype();
1590 // First invoke the collector.
1591 EmulatedStackFrame filterFrame = EmulatedStackFrame.create(collector.type());
1593 collector
[all...] |
| /libcore/luni/src/test/java/libcore/java/lang/invoke/ |
| H A D | MethodHandleCombinersTest.java | 1343 MethodHandle collector = trailingRef.asCollector(String[].class, 2);
1344 assertEquals(99, (int) collector.invoke("a", "b", "c"));
1348 collector.invoke("a", "b");
1355 collector.invoke("a", "b", "c", "d");
|