| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | ReferencePipeline.java | 507 public final <R, A> R collect(Collector<? super P_OUT, A, R> collector) {
510 && (collector.characteristics().contains(Collector.Characteristics.CONCURRENT))
511 … && (!isOrdered() || collector.characteristics().contains(Collector.Characteristics.UNORDERED))) {
512 container = collector.supplier().get();
513 BiConsumer<A, ? super P_OUT> accumulator = collector.accumulator();
517 container = evaluate(ReduceOps.makeRef(collector));
519 return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)
521 : collector.finisher().apply(container);
|
| D | ReduceOps.java | 156 makeRef(Collector<? super T, I, ?> collector) {
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)
|
| D | Stream.java | 807 <R, A> R collect(Collector<? super T, A, R> collector); in collect() argument
|
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| D | FlagOpTest.java | 160 testFlagsSetSequence(CollectorOps::collector); in testFlagsParallelCollect()
194 testFlagsClearSequence(CollectorOps::collector); in testFlagsClearParallelCollect()
234 ops.add(CollectorOps.collector()); in testFlagsSizedOrderedParallelCollect()
240 ops.add(CollectorOps.collector()); in testFlagsSizedOrderedParallelCollect()
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | GroupByOpTest.java | 63 Collector<Integer, Map<Boolean, List<Integer>>, Map<Boolean, List<Integer>>> collector in testBypassCollect() local
66 Map<Boolean, List<Integer>> m = collector.supplier().get(); in testBypassCollect()
69 collector.accumulator().accept(m, i); in testBypassCollect()
|
| 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();
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | CollectorOps.java | 34 public static <E_IN> StatefulTestOp<E_IN> collector() { in collector() method in CollectorOps
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | CollectorOps.java | 35 public static <E_IN> StatefulTestOp<E_IN> collector() { in collector() method in CollectorOps
|
| /libcore/ojluni/src/main/java/java/lang/invoke/ |
| D | Transformers.java | 1534 private final MethodHandle collector; field in Transformers.CollectArguments
1555 CollectArguments(MethodHandle target, MethodHandle collector, int pos, in CollectArguments() argument
1560 this.collector = collector; in CollectArguments()
1563 final int numFilterArgs = collector.type().parameterCount(); in CollectArguments()
1576 final Class<?> collectorRType = collector.type().rtype(); in CollectArguments()
1592 EmulatedStackFrame filterFrame = EmulatedStackFrame.create(collector.type()); in transform()
1594 collector.invoke(filterFrame); in transform()
|
| /libcore/luni/src/test/java/libcore/java/lang/invoke/ |
| D | MethodHandleCombinersTest.java | 1343 MethodHandle collector = trailingRef.asCollector(String[].class, 2); in testAsCollector() local
1344 assertEquals(99, (int) collector.invoke("a", "b", "c")); in testAsCollector()
1348 collector.invoke("a", "b"); in testAsCollector()
1355 collector.invoke("a", "b", "c", "d"); in testAsCollector()
|