| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| H A D | FlatteningSubscriberTest.java | 54 Subscription downstream = getDownstreamFromDelegate(); in requestOne() local
69 Subscription downstream = getDownstreamFromDelegate(); in requestTwo() local
85 Subscription downstream = getDownstreamFromDelegate(); in requestThree() local
110 Subscription downstream = getDownstreamFromDelegate(); in requestInfinite() local
132 Subscription downstream = getDownstreamFromDelegate(); in onCompleteDelayedUntilAllDataDelivered() local
156 Subscription downstream = getDownstreamFromDelegate(); in onErrorDropsBufferedData() local
173 Subscription downstream = getDownstreamFromDelegate(); in requestsFromDownstreamDoNothingAfterOnComplete() local
193 Subscription downstream = getDownstreamFromDelegate(); in requestsFromDownstreamDoNothingAfterOnError() local
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/stream/ |
| D | Sink.java | 250 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedReference
252 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference()
282 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedInt
284 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt()
314 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedLong
316 public ChainedLong(Sink<? super E_OUT> downstream) { in ChainedLong()
346 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedDouble
348 public ChainedDouble(Sink<? super E_OUT> downstream) { in ChainedDouble()
|
| D | SortedOps.java | 310 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink()
420 AbstractIntSortingSink(Sink<? super Integer> downstream) { in AbstractIntSortingSink()
438 SizedIntSortingSink(Sink<? super Integer> downstream) { in SizedIntSortingSink()
519 AbstractLongSortingSink(Sink<? super Long> downstream) { in AbstractLongSortingSink()
537 SizedLongSortingSink(Sink<? super Long> downstream) { in SizedLongSortingSink()
618 AbstractDoubleSortingSink(Sink<? super Double> downstream) { in AbstractDoubleSortingSink()
636 SizedDoubleSortingSink(Sink<? super Double> downstream) { in SizedDoubleSortingSink()
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/stream/ |
| H A D | Sink.java | 250 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedReference
252 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference()
282 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedInt
284 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt()
314 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedLong
316 public ChainedLong(Sink<? super E_OUT> downstream) { in ChainedLong()
346 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedDouble
348 public ChainedDouble(Sink<? super E_OUT> downstream) { in ChainedDouble()
|
| H A D | SortedOps.java | 310 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink()
420 AbstractIntSortingSink(Sink<? super Integer> downstream) { in AbstractIntSortingSink()
438 SizedIntSortingSink(Sink<? super Integer> downstream) { in SizedIntSortingSink()
519 AbstractLongSortingSink(Sink<? super Long> downstream) { in AbstractLongSortingSink()
537 SizedLongSortingSink(Sink<? super Long> downstream) { in SizedLongSortingSink()
618 AbstractDoubleSortingSink(Sink<? super Double> downstream) { in AbstractDoubleSortingSink()
636 SizedDoubleSortingSink(Sink<? super Double> downstream) { in SizedDoubleSortingSink()
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/22/libcore/ojluni/src/main/java/java/util/stream/ |
| D | Sink.java | 250 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedReference
252 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference()
282 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedInt
284 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt()
314 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedLong
316 public ChainedLong(Sink<? super E_OUT> downstream) { in ChainedLong()
346 protected final Sink<? super E_OUT> downstream; field in Sink.ChainedDouble
348 public ChainedDouble(Sink<? super E_OUT> downstream) { in ChainedDouble()
|
| D | SortedOps.java | 310 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink()
420 AbstractIntSortingSink(Sink<? super Integer> downstream) { in AbstractIntSortingSink()
438 SizedIntSortingSink(Sink<? super Integer> downstream) { in SizedIntSortingSink()
519 AbstractLongSortingSink(Sink<? super Long> downstream) { in AbstractLongSortingSink()
537 SizedLongSortingSink(Sink<? super Long> downstream) { in SizedLongSortingSink()
618 AbstractDoubleSortingSink(Sink<? super Double> downstream) { in AbstractDoubleSortingSink()
636 SizedDoubleSortingSink(Sink<? super Double> downstream) { in SizedDoubleSortingSink()
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/stream/Collectors/ |
| H A D | CollectorsTest.java | 94 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.MappingAssertion
96 MappingAssertion(Function<T, V> mapper, CollectorAssertion<V, R> downstream) { in MappingAssertion()
111 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.FlatMappingAssertion
114 CollectorAssertion<V, R> downstream) { in FlatMappingAssertion()
129 private final CollectorAssertion<T, R> downstream; field in CollectorsTest.FilteringAssertion
131 public FilteringAssertion(Predicate<T> filter, CollectorAssertion<T, R> downstream) { in FilteringAssertion()
147 private final CollectorAssertion<T,V> downstream; field in CollectorsTest.GroupingByAssertion
150 CollectorAssertion<T, V> downstream) { in GroupingByAssertion()
208 private final CollectorAssertion<T,D> downstream; field in CollectorsTest.PartitioningByAssertion
210 PartitioningByAssertion(Predicate<T> predicate, CollectorAssertion<T, D> downstream) { in PartitioningByAssertion()
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| H A D | CollectorsTest.java | 91 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.MappingAssertion
93 MappingAssertion(Function<T, V> mapper, CollectorAssertion<V, R> downstream) { in MappingAssertion()
108 private final CollectorAssertion<V, R> downstream; field in CollectorsTest.FlatMappingAssertion
111 CollectorAssertion<V, R> downstream) { in FlatMappingAssertion()
126 private final CollectorAssertion<T, R> downstream; field in CollectorsTest.FilteringAssertion
128 public FilteringAssertion(Predicate<T> filter, CollectorAssertion<T, R> downstream) { in FilteringAssertion()
144 private final CollectorAssertion<T,V> downstream; field in CollectorsTest.GroupingByAssertion
147 CollectorAssertion<T, V> downstream) { in GroupingByAssertion()
205 private final CollectorAssertion<T,D> downstream; field in CollectorsTest.PartitioningByAssertion
207 PartitioningByAssertion(Predicate<T> predicate, CollectorAssertion<T, D> downstream) { in PartitioningByAssertion()
|
| H A D | TabulatorsTest.java | 85 private final TabulationAssertion<T,V> downstream; field in TabulatorsTest.GroupedMapAssertion
89 TabulationAssertion<T, V> downstream) { in GroupedMapAssertion()
145 private final TabulationAssertion<T,D> downstream; field in TabulatorsTest.PartitionAssertion
148 TabulationAssertion<T, D> downstream) { in PartitionAssertion()
|
| /aosp_15_r20/libcore/ojluni/annotations/flagged_api/java/util/stream/ |
| H A D | Collectors.annotated.java | 49 …? super T,? extends U> mapper, java.util.stream.Collector<? super U,A,R> downstream) { throw new R… in mapping()
51 …m.Stream<? extends U>> mapper, java.util.stream.Collector<? super U,A,R> downstream) { throw new R… in flatMapping()
53 …redicate<? super T> predicate, java.util.stream.Collector<? super T,A,R> downstream) { throw new R… in filtering()
55 …am.Collector<T,A,RR> collectingAndThen(java.util.stream.Collector<T,A,R> downstream, java.util.fun… in collectingAndThen() argument
83 …per T,? extends K> classifier, java.util.stream.Collector<? super T,A,D> downstream) { throw new R… in groupingBy()
85 …nction.Supplier<M> mapFactory, java.util.stream.Collector<? super T,A,D> downstream) { throw new R… in groupingBy()
89 …per T,? extends K> classifier, java.util.stream.Collector<? super T,A,D> downstream) { throw new R… in groupingByConcurrent()
91 …nction.Supplier<M> mapFactory, java.util.stream.Collector<? super T,A,D> downstream) { throw new R… in groupingByConcurrent()
95 …redicate<? super T> predicate, java.util.stream.Collector<? super T,A,D> downstream) { throw new R… in partitioningBy()
|
| /aosp_15_r20/development/tools/repo_diff/service/repodiff/ |
| H A D | config.json | 15 "downstream": { object
25 "downstream": { object
36 "downstream": { object
47 "downstream": { object
58 "downstream": { object
|
| /aosp_15_r20/packages/modules/Connectivity/Tethering/apishim/common/com/android/networkstack/tethering/apishim/common/ |
| D | BpfCoordinatorShim.java | 146 public abstract boolean tetherOffloadRuleAdd(boolean downstream, @NonNull Tether4Key key, in tetherOffloadRuleAdd()
156 public abstract boolean tetherOffloadRuleRemove(boolean downstream, @NonNull Tether4Key key); in tetherOffloadRuleRemove()
166 public abstract void tetherOffloadRuleForEach(boolean downstream, in tetherOffloadRuleForEach()
183 public abstract boolean attachProgram(@NonNull String iface, boolean downstream, in attachProgram()
|
| /aosp_15_r20/packages/modules/Connectivity/Tethering/apishim/30/com/android/networkstack/tethering/apishim/api30/ |
| D | BpfCoordinatorShimImpl.java | 149 public boolean tetherOffloadRuleAdd(boolean downstream, @NonNull Tether4Key key, in tetherOffloadRuleAdd()
156 public boolean tetherOffloadRuleRemove(boolean downstream, @NonNull Tether4Key key) { in tetherOffloadRuleRemove()
162 public void tetherOffloadRuleForEach(boolean downstream, in tetherOffloadRuleForEach()
168 public boolean attachProgram(String iface, boolean downstream, boolean ipv4) { in attachProgram()
|
| /aosp_15_r20/packages/modules/Connectivity/Tethering/apishim/31/com/android/networkstack/tethering/apishim/api31/ |
| D | BpfCoordinatorShimImpl.java | 363 public boolean tetherOffloadRuleAdd(boolean downstream, @NonNull Tether4Key key, in tetherOffloadRuleAdd()
394 public boolean tetherOffloadRuleRemove(boolean downstream, @NonNull Tether4Key key) { in tetherOffloadRuleRemove()
429 public void tetherOffloadRuleForEach(boolean downstream, in tetherOffloadRuleForEach()
443 public boolean attachProgram(String iface, boolean downstream, boolean ipv4) { in attachProgram()
|
| /aosp_15_r20/development/tools/repo_diff/ |
| H A D | git_commits_not_upstreamed.py | 39 def __init__(self, working_dir, upstream, downstream): argument
61 def find_insertion_commits(upstream, downstream, working_dir): argument
91 def find(upstream, downstream, working_dir): argument
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/reactivex/rxjava2/rxjava/2.2.9/ |
| HD | rxjava-2.2.9.jar | ... reactivestreams.Subscription {
final org.reactivestreams.Subscriber downstream
org.reactivestreams.Subscription upstream
boolean done
public void ... |
| /aosp_15_r20/packages/modules/Connectivity/Tethering/src/com/android/networkstack/tethering/ |
| D | BpfUtils.java | 64 private static String makeProgPath(boolean downstream, int ipVersion, boolean ether) { in makeProgPath()
77 public static void attachProgram(@NonNull String iface, boolean downstream, boolean ipv4) in attachProgram()
|
| D | IPv6TetheringCoordinator.java | 87 public void addActiveDownstream(IpServer downstream, int mode) { in addActiveDownstream()
103 public void removeActiveDownstream(IpServer downstream) { in removeActiveDownstream()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/metrics/ |
| H A D | BytesReadTrackingPublisher.java | 48 private final Subscriber<? super ByteBuffer> downstream; field in BytesReadTrackingPublisher.BytesReadTracker
51 private BytesReadTracker(Subscriber<? super ByteBuffer> downstream, AtomicLong bytesRead) { in BytesReadTracker()
|
| /aosp_15_r20/external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| H A D | FlowableCharSequence.java | 28 final Subscriber<? super Integer> downstream; field in FlowableCharSequence.CharSequenceSubscription
38 CharSequenceSubscription(Subscriber<? super Integer> downstream, CharSequence string) { in CharSequenceSubscription()
|
| H A D | FlowableSplit.java | 52 final Subscriber<? super String> downstream; field in FlowableSplit.SplitSubscriber
81 SplitSubscriber(Subscriber<? super String> downstream, Pattern pattern, int bufferSize) { in SplitSubscriber()
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| H A D | FlagOpTest.java | 56 TestFlagPassThroughOp<T> downstream; field in FlagOpTest.TestFlagPassThroughOp
62 void set(TestFlagPassThroughOp<T> upstream, TestFlagPassThroughOp<T> downstream) { in set()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| H A D | Delay.kt | 201 scopedFlow { downstream -> in debounceInternal() method
271 return scopedFlow { downstream -> in sample() method
|
| /aosp_15_r20/packages/modules/Connectivity/staticlibs/device/com/android/net/module/util/ |
| D | PrivateAddressCoordinator.java | 173 final LinkAddress downstream = entry.getValue(); in handleMaybePrefixConflict() local
390 final IpPrefix downstream = asIpPrefix(mCachedAddresses.valueAt(i)); in getInUseDownstreamPrefix() local
|