/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...] |
/external/openssh/ |
channels.c | 124 Channel *downstream; /* Downstream mux*/ member in struct:__anon28961 455 if (permitted_opens[i].downstream != c) 477 permitted_opens[i].downstream = NULL; 2630 Channel *downstream; local [all...] |
/prebuilts/sdk/24/ |
android.jar | |