| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | Sink.java | 247 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 …]
|
| D | SortedOps.java | 309 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink() argument
310 super(downstream); in AbstractRefSortingSink()
349 downstream.begin(offset); in end()
352 downstream.accept(array[i]); in end()
355 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++) in end()
356 downstream.accept(array[i]); in end()
358 downstream.end(); in end()
388 downstream.begin(list.size()); in end()
390 list.forEach(downstream::accept); in end()
394 if (downstream.cancellationRequested()) break; in end()
[all …]
|
| D | Collectors.java | 352 Collector<? super U, A, R> downstream) {
353 BiConsumer<A, ? super U> downstreamAccumulator = downstream.accumulator();
354 return new CollectorImpl<>(downstream.supplier(),
356 downstream.combiner(), downstream.finisher(),
357 downstream.characteristics());
378 public static<T,A,R,RR> Collector<T,A,RR> collectingAndThen(Collector<T,A,R> downstream,
380 Set<Collector.Characteristics> characteristics = downstream.characteristics();
390 return new CollectorImpl<>(downstream.supplier(),
391 downstream.accumulator(),
392 downstream.combiner(),
[all …]
|
| D | DistinctOps.java | 136 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()
178 downstream.accept(t); in makeRef()
|
| D | ReferencePipeline.java | 179 downstream.begin(-1);
185 downstream.accept(u);
203 downstream.accept(mapper.apply(u));
221 downstream.accept(mapper.applyAsInt(u));
239 downstream.accept(mapper.applyAsLong(u));
257 downstream.accept(mapper.applyAsDouble(u));
275 downstream.begin(-1);
283 result.sequential().forEach(downstream);
301 IntConsumer downstreamAsInt = downstream::accept;
304 downstream.begin(-1);
[all …]
|
| D | IntPipeline.java | 203 downstream.accept((long) t); in asLongStream()
220 downstream.accept((double) t);
243 downstream.accept(mapper.applyAsInt(t));
261 downstream.accept(mapper.apply(t));
279 downstream.accept(mapper.applyAsLong(t));
297 downstream.accept(mapper.applyAsDouble(t));
314 downstream.begin(-1);
322 result.sequential().forEach(i -> downstream.accept(i));
354 downstream.begin(-1);
360 downstream.accept(t);
[all …]
|
| D | LongPipeline.java | 201 downstream.accept((double) t); in asDoubleStream()
224 downstream.accept(mapper.applyAsLong(t));
242 downstream.accept(mapper.apply(t));
260 downstream.accept(mapper.applyAsInt(t));
278 downstream.accept(mapper.applyAsDouble(t));
295 downstream.begin(-1);
303 result.sequential().forEach(i -> downstream.accept(i));
335 downstream.begin(-1);
341 downstream.accept(t);
360 downstream.accept(t);
|
| D | SliceOps.java | 199 downstream.begin(calcSize(size, skip, m)); in makeRef()
207 downstream.accept(t); in makeRef()
217 return m == 0 || downstream.cancellationRequested(); in makeRef()
311 downstream.begin(calcSize(size, skip, m));
319 downstream.accept(t);
329 return m == 0 || downstream.cancellationRequested();
423 downstream.begin(calcSize(size, skip, m));
431 downstream.accept(t);
441 return m == 0 || downstream.cancellationRequested();
535 downstream.begin(calcSize(size, skip, m));
[all …]
|
| D | DoublePipeline.java | 206 downstream.accept(mapper.applyAsDouble(t)); in map()
224 downstream.accept(mapper.apply(t));
242 downstream.accept(mapper.applyAsInt(t));
260 downstream.accept(mapper.applyAsLong(t));
277 downstream.begin(-1);
285 result.sequential().forEach(i -> downstream.accept(i));
317 downstream.begin(-1);
323 downstream.accept(t);
342 downstream.accept(t);
|
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| D | FlagOpTest.java | 56 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/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | TabulatorsTest.java | 85 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/ |
| D | JavaLibrary.bp | 138 // In the downstream branch master-icu-dev, the resource files are generated.
|