| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| 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
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/metrics/ |
| 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()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableCharSequence.java | 32 final Subscriber<? super Integer> downstream; field in FlowableCharSequence.CharSequenceSubscription
42 CharSequenceSubscription(Subscriber<? super Integer> downstream, CharSequence string) { in CharSequenceSubscription()
|
| D | FlowableSplit.java | 56 final Subscriber<? super String> downstream; field in FlowableSplit.SplitSubscriber
85 SplitSubscriber(Subscriber<? super String> downstream, Pattern pattern, int bufferSize) { in SplitSubscriber()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Delay.kt | 207 scopedFlow { downstream -> in debounceInternal() method
277 return scopedFlow { downstream -> in sample() method
|
| /external/cronet/net/tools/content_decoder_tool/ |
| D | content_decoder_tool.cc | 72 std::unique_ptr<SourceStream> downstream; in ContentDecoderToolProcessInput() local
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 28 def __init__(self, transformation, downstream): argument
|
| /external/cronet/net/url_request/ |
| D | url_request_http_job.cc | 1363 std::unique_ptr<FilterSourceStream> downstream; in SetUpSourceStream() local
|
| /external/libbpf/.github/actions/build-selftests/ |
| D | vmlinux.h | 85717 struct pci_dev *downstream; member
|
| /external/bcc/libbpf-tools/powerpc/ |
| D | vmlinux_600.h | 125185 struct pci_dev *downstream; member
|
| D | vmlinux.h | 125185 struct pci_dev *downstream; member
|
| /external/bcc/libbpf-tools/x86/ |
| D | vmlinux_518.h | 81366 struct pci_dev *downstream; member
|
| D | vmlinux.h | 81366 struct pci_dev *downstream; member
|
| /external/bcc/libbpf-tools/arm64/ |
| D | vmlinux.h | 107707 struct pci_dev *downstream; member
|
| D | vmlinux_608.h | 107707 struct pci_dev *downstream; member
|
| /external/bcc/libbpf-tools/riscv/ |
| D | vmlinux.h | 77415 struct pci_dev *downstream; member
|
| D | vmlinux_602.h | 77415 struct pci_dev *downstream; member
|