HomeSort by relevance Sort by last modified time
    Searched defs:downstream (Results 1 - 6 of 6) sorted by null

  /libcore/ojluni/src/main/java/java/util/stream/
DistinctOps.java 133 downstream.begin(-1);
140 downstream.end();
148 downstream.accept(lastSeen = null);
151 downstream.accept(lastSeen = t);
162 downstream.begin(-1);
168 downstream.end();
175 downstream.accept(t);
Sink.java 77 * sends some elements "downstream" -- into the {@code Sink} for the mapping
78 * stage, which in turn sends integral values downstream into the {@code Sink}
81 * the correct {@code accept} method on its downstream {@code Sink}. Similarly,
92 * {@code Sink.OfInt}, but also maintain a {@code downstream} field which
93 * represents the downstream {@code Sink}, and implement the methods
95 * delegate to the downstream {@code Sink}. Most implementations of
102 * downstream.accept(mapper.applyAsInt(u));
108 * to receive elements of type {@code U} as input, and pass the downstream sink
110 * must call the {@code accept(int)} method when emitting values to the downstream.
112 * {@code int} and passes the resulting value to the downstream {@code Sink}
246 protected final Sink<? super E_OUT> downstream; field in class:Sink.ChainedReference
278 protected final Sink<? super E_OUT> downstream; field in class:Sink.ChainedInt
310 protected final Sink<? super E_OUT> downstream; field in class:Sink.ChainedLong
342 protected final Sink<? super E_OUT> downstream; field in class:Sink.ChainedDouble
    [all...]
SortedOps.java 290 * sorted and then pushed downstream.
294 * pushing elements downstream will preserve the short-circuiting protocol
295 * by calling {@code downstream.cancellationRequested()} and checking the
309 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) {
310 super(downstream);
316 * can be preserved when the sorted elements are pushed downstream.
349 downstream.begin(offset);
352 downstream.accept(array[i]);
355 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
356 downstream.accept(array[i])
    [all...]
  /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
FlagOpTest.java 56 TestFlagPassThroughOp<T> downstream; field in class:FlagOpTest.TestFlagPassThroughOp
62 void set(TestFlagPassThroughOp<T> upstream, TestFlagPassThroughOp<T> downstream) {
64 this.downstream = downstream;
74 if (downstream != null) {
75 assertTrue(flags == downstream.wrapFlags);
  /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
TabulatorsTest.java 85 private final TabulationAssertion<T,V> downstream; field in class:TabulatorsTest.GroupedMapAssertion
89 TabulationAssertion<T, V> downstream) {
92 this.downstream = downstream;
103 downstream.assertValue(entry.getValue(),
145 private final TabulationAssertion<T,D> downstream; field in class:TabulatorsTest.PartitionAssertion
148 TabulationAssertion<T, D> downstream) {
150 this.downstream = downstream;
159 downstream.assertValue(map.get(true), () -> source.get().filter(predicate), ordered)
    [all...]
  /prebuilts/sdk/24/
android.jar 

Completed in 342 milliseconds