Home
last modified time | relevance | path

Searched refs:downstream (Results 1 – 15 of 15) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DSink.java247 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedReference
249 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference() argument
250 this.downstream = Objects.requireNonNull(downstream); in ChainedReference()
255 downstream.begin(size); in begin()
260 downstream.end(); in end()
265 return downstream.cancellationRequested(); in cancellationRequested()
279 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedInt
281 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt() argument
282 this.downstream = Objects.requireNonNull(downstream); in ChainedInt()
287 downstream.begin(size); in begin()
[all …]
DSortedOps.java310 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink() argument
311 super(downstream); in AbstractRefSortingSink()
354 downstream.begin(offset); in end()
357 downstream.accept(array[i]); in end()
360 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++) in end()
361 downstream.accept(array[i]); in end()
363 downstream.end(); in end()
393 downstream.begin(list.size()); in end()
395 list.forEach(downstream::accept); in end()
399 if (downstream.cancellationRequested()) break; in end()
[all …]
DCollectors.java467 Collector<? super U, A, R> downstream) {
468 BiConsumer<A, ? super U> downstreamAccumulator = downstream.accumulator();
469 return new CollectorImpl<>(downstream.supplier(),
471 downstream.combiner(), downstream.finisher(),
472 downstream.characteristics());
512 Collector<? super U, A, R> downstream) {
513 BiConsumer<A, ? super U> downstreamAccumulator = downstream.accumulator();
514 return new CollectorImpl<>(downstream.supplier(),
521 downstream.combiner(), downstream.finisher(),
522 downstream.characteristics());
[all …]
DReferencePipeline.java185 downstream.begin(-1);
191 downstream.accept(u);
209 downstream.accept(mapper.apply(u));
227 downstream.accept(mapper.applyAsInt(u));
245 downstream.accept(mapper.applyAsLong(u));
263 downstream.accept(mapper.applyAsDouble(u));
283 downstream.begin(-1);
291 result.sequential().forEach(downstream);
295 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstream));
308 return downstream.cancellationRequested();
[all …]
DDistinctOps.java136 downstream.begin(-1); in makeRef()
143 downstream.end(); in makeRef()
151 downstream.accept(lastSeen = null); in makeRef()
154 downstream.accept(lastSeen = t); in makeRef()
165 downstream.begin(-1); in makeRef()
171 downstream.end(); in makeRef()
177 downstream.accept(t); in makeRef()
DIntPipeline.java189 downstream.accept(mapper.apply(t)); in mapToObj()
218 downstream.accept((long) t);
234 downstream.accept((double) t);
257 downstream.accept(mapper.applyAsInt(t));
281 downstream.accept(mapper.applyAsLong(t));
299 downstream.accept(mapper.applyAsDouble(t));
319 IntConsumer downstreamAsInt = downstream::accept;
323 downstream.begin(-1);
335 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstreamAsInt));
348 return downstream.cancellationRequested();
[all …]
DLongPipeline.java186 downstream.accept(mapper.apply(t)); in mapToObj()
216 downstream.accept((double) t);
239 downstream.accept(mapper.applyAsLong(t));
263 downstream.accept(mapper.applyAsInt(t));
281 downstream.accept(mapper.applyAsDouble(t));
301 LongConsumer downstreamAsLong = downstream::accept;
305 downstream.begin(-1);
317 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstreamAsLong));
330 return downstream.cancellationRequested();
349 downstream.begin(-1);
[all …]
DDoublePipeline.java185 downstream.accept(mapper.apply(t)); in mapToObj()
222 downstream.accept(mapper.applyAsDouble(t));
246 downstream.accept(mapper.applyAsInt(t));
264 downstream.accept(mapper.applyAsLong(t));
284 DoubleConsumer downstreamAsDouble = downstream::accept;
288 downstream.begin(-1);
300 … do { } while (!downstream.cancellationRequested() && s.tryAdvance(downstreamAsDouble));
313 return downstream.cancellationRequested();
333 downstream.begin(-1);
339 mapper.accept(t, (DoubleConsumer) downstream);
[all …]
DSliceOps.java195 downstream.begin(calcSize(size, skip, m)); in makeRef()
203 downstream.accept(t); in makeRef()
213 return m == 0 || downstream.cancellationRequested(); in makeRef()
313 downstream.begin(calcSize(size, skip, m));
321 downstream.accept(t);
331 return m == 0 || downstream.cancellationRequested();
431 downstream.begin(calcSize(size, skip, m));
439 downstream.accept(t);
449 return m == 0 || downstream.cancellationRequested();
549 downstream.begin(calcSize(size, skip, m));
[all …]
DWhileOps.java96 downstream.begin(-1); in makeTakeWhileRef()
102 downstream.accept(t); in makeTakeWhileRef()
108 return !take || downstream.cancellationRequested(); in makeTakeWhileRef()
156 downstream.begin(-1);
162 downstream.accept(t);
168 return !take || downstream.cancellationRequested();
216 downstream.begin(-1);
222 downstream.accept(t);
228 return !take || downstream.cancellationRequested();
276 downstream.begin(-1);
[all …]
/libcore/ojluni/src/test/java/util/stream/Collectors/
DCollectorsTest.java94 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.MappingAssertion
96 MappingAssertion(Function<T, V> mapper, CollectorAssertion<V, R> downstream) { in MappingAssertion() argument
98 this.downstream = downstream; in MappingAssertion()
103 downstream.assertValue(value, in assertValue()
111 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.FlatMappingAssertion
114 CollectorAssertion<V, R> downstream) { in FlatMappingAssertion() argument
116 this.downstream = downstream; in FlatMappingAssertion()
121 downstream.assertValue(value, in assertValue()
129 private final CollectorAssertion<T, R> downstream; field in CollectorsTest.FilteringAssertion
131 public FilteringAssertion(Predicate<T> filter, CollectorAssertion<T, R> downstream) { in FilteringAssertion() argument
[all …]
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DCollectorsTest.java91 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.MappingAssertion
93 MappingAssertion(Function<T, V> mapper, CollectorAssertion<V, R> downstream) { in MappingAssertion() argument
95 this.downstream = downstream; in MappingAssertion()
100 downstream.assertValue(value, in assertValue()
108 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.FlatMappingAssertion
111 CollectorAssertion<V, R> downstream) { in FlatMappingAssertion() argument
113 this.downstream = downstream; in FlatMappingAssertion()
118 downstream.assertValue(value, in assertValue()
126 private final CollectorAssertion<T, R> downstream; field in CollectorsTest.FilteringAssertion
128 public FilteringAssertion(Predicate<T> filter, CollectorAssertion<T, R> downstream) { in FilteringAssertion() argument
[all …]
DTabulatorsTest.java85 private final TabulationAssertion<T,V> downstream; field in TabulatorsTest.GroupedMapAssertion
89 TabulationAssertion<T, V> downstream) { in GroupedMapAssertion() argument
92 this.downstream = downstream; in GroupedMapAssertion()
103 downstream.assertValue(entry.getValue(), in assertValue()
145 private final TabulationAssertion<T,D> downstream; field in TabulatorsTest.PartitionAssertion
148 TabulationAssertion<T, D> downstream) { in PartitionAssertion() argument
150 this.downstream = downstream; in PartitionAssertion()
159 downstream.assertValue(map.get(true), () -> source.get().filter(predicate), ordered); in assertValue()
160 … downstream.assertValue(map.get(false), () -> source.get().filter(predicate.negate()), ordered); in assertValue()
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DFlagOpTest.java56 TestFlagPassThroughOp<T> downstream; field in FlagOpTest.TestFlagPassThroughOp
62 void set(TestFlagPassThroughOp<T> upstream, TestFlagPassThroughOp<T> downstream) { in set() argument
64 this.downstream = downstream; in set()
74 if (downstream != null) { in opWrapSink()
75 assertTrue(flags == downstream.wrapFlags); in opWrapSink()
/libcore/ojluni/annotations/flagged_api/java/util/stream/
DCollectors.annotated.java49 …super T,? extends U> mapper, java.util.stream.Collector<? super U,A,R> downstream) { throw new Run… in mapping() argument
51 …Stream<? extends U>> mapper, java.util.stream.Collector<? super U,A,R> downstream) { throw new Run… in flatMapping() argument
53 …dicate<? super T> predicate, java.util.stream.Collector<? super T,A,R> downstream) { throw new Run… in filtering() argument
55 ….Collector<T,A,RR> collectingAndThen(java.util.stream.Collector<T,A,R> downstream, java.util.funct… in collectingAndThen() argument
83 …r T,? extends K> classifier, java.util.stream.Collector<? super T,A,D> downstream) { throw new Run… in groupingBy() argument
85 …tion.Supplier<M> mapFactory, java.util.stream.Collector<? super T,A,D> downstream) { throw new Run… in groupingBy() argument
89 …r T,? extends K> classifier, java.util.stream.Collector<? super T,A,D> downstream) { throw new Run… in groupingByConcurrent() argument
91 …tion.Supplier<M> mapFactory, java.util.stream.Collector<? super T,A,D> downstream) { throw new Run… in groupingByConcurrent() argument
95 …dicate<? super T> predicate, java.util.stream.Collector<? super T,A,D> downstream) { throw new Run… in partitioningBy() argument