Searched defs:collector (Results 1 - 7 of 7) sorted by relevance
/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/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/main/java/java/util/stream/ |
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
|
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);
|
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
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...] |
Completed in 7317 milliseconds