| /external/exoplayer/tree/library/hls/src/test/java/com/google/android/exoplayer2/source/hls/ |
| D | Aes128DataSourceTest.java | 39 UpstreamDataSource upstream = new UpstreamDataSource(); in test_OpenCallsUpstreamOpen_CloseCallsUpstreamClose() local
53 UpstreamDataSource upstream = in test_OpenCallsUpstreamThrowingOpen_CloseCallsUpstreamClose() local
80 public TestAes123DataSource(DataSource upstream, byte[] encryptionKey, byte[] encryptionIv) { in TestAes123DataSource()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/upstream/ |
| D | PriorityDataSource.java | 40 private final DataSource upstream; field in PriorityDataSource
49 public PriorityDataSource(DataSource upstream, PriorityTaskManager priorityTaskManager, in PriorityDataSource()
|
| D | TeeDataSource.java | 31 private final DataSource upstream; field in TeeDataSource
41 public TeeDataSource(DataSource upstream, DataSink dataSink) { in TeeDataSource()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/upstream/crypto/ |
| D | AesCipherDataSource.java | 36 private final DataSource upstream; field in AesCipherDataSource
41 public AesCipherDataSource(byte[] secretKey, DataSource upstream) { in AesCipherDataSource()
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/upstream/cache/ |
| D | CacheDataSourceTest.java | 294 FakeDataSource upstream = new FakeDataSource(); in unknownLengthContentReadInOneConnectionAndLengthIsResolved() local
313 FakeDataSource upstream = new FakeDataSource(); in ignoreCacheForUnsetLengthRequests() local
336 FakeDataSource upstream = new FakeDataSource(); in switchToCacheSourceWithReadOnlyCacheDataSource() local
371 FakeDataSource upstream = new FakeDataSource(); in switchToCacheSourceWithNonBlockingCacheDataSource() local
416 FakeDataSource upstream = new FakeDataSource(); in deleteCachedWhileReadingFromUpstreamWithReadOnlyCacheDataSourceDoesNotCrash() local
447 FakeDataSource upstream = new FakeDataSource(); in deleteCachedWhileReadingFromUpstreamWithBlockingCacheDataSourceDoesNotBlock() local
|
| /external/exoplayer/tree/library/hls/src/main/java/com/google/android/exoplayer2/source/hls/ |
| D | Aes128DataSource.java | 50 private final DataSource upstream; field in Aes128DataSource
61 public Aes128DataSource(DataSource upstream, byte[] encryptionKey, byte[] encryptionIv) { in Aes128DataSource()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/source/ |
| D | IcyDataSource.java | 48 private final DataSource upstream; field in IcyDataSource
59 public IcyDataSource(DataSource upstream, int metadataIntervalBytes, Listener listener) { in IcyDataSource()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Share.kt | 152 @JvmField val upstream: Flow<T>, constant in kotlinx.coroutines.flow.SharingConfig
165 val upstream = dropChannelOperators() in configureSharing() constant
|
| D | Distinct.kt | 70 private val upstream: Flow<T>, constant in kotlinx.coroutines.flow.DistinctFlowImpl
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | StateInTest.kt | 51 val upstream = flow { in <lambda>() constant
|
| D | ShareInBufferTest.kt | 26 val upstream = flow { in <lambda>() constant
|
| D | ShareInTest.kt | 92 val upstream = flow { in <lambda>() constant
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableSplit.java | 39 public Publisher<String> apply(Flowable<String> upstream) { in apply()
68 Subscription upstream; field in FlowableSplit.SplitSubscriber
|
| /external/rust/crates/codespan-reporting/examples/ |
| D | readme_preview.rs | 195 upstream: W, field
242 upstream: W, field
|
| /external/okio/okio/src/commonMain/kotlin/okio/ |
| D | PeekSource.kt | 29 private val upstream: BufferedSource constant in okio.PeekSource
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharingStressTest.kt | 73 val upstream = flow { in <lambda>() constant
|
| /external/oss-fuzz/projects/nginx/fuzz/ |
| D | http_request_fuzzer.cc | 114 static ngx_http_upstream_t *upstream; variable
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 104 def __init__(self, upstream): argument
|
| /external/adhd/cras/src/server/ |
| D | cras_dsp_pipeline.c | 643 struct instance *upstream = find_instance_by_plugin( in calculate_audio_delay() local
|