| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 17 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
35 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
61 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
92 val publisher = flowPublish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
129 val publisher = flowPublish<Int>(Dispatchers.Unconfined) { in <lambda>() constant
149 val publisher = flowPublish(currentDispatcher() + exceptionHandler) { in <lambda>() constant
194 val publisher = flowPublish<Int>(handler + Dispatchers.Unconfined) { in <lambda>() constant
258 val publisher = flowPublish<Int>(Dispatchers.Unconfined) { in <lambda>() constant
278 val publisher = flowPublish { in <lambda>() constant
|
| D | PublisherAsFlowTest.kt | 19 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
47 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
68 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
85 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
104 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
125 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
|
| D | PublisherCollectTest.kt | 21 val publisher = JFlow.Publisher<Int> { subscriber -> in <lambda>() constant
62 val publisher = Publisher<Int> { subscriber -> in <lambda>() constant
104 val publisher = Publisher<Int> { subscriber -> in <lambda>() constant
|
| D | AwaitTest.kt | 18 val publisher = JFlow.Publisher<Int> { s -> in <lambda>() constant
|
| D | FlowAsPublisherTest.kt | 81 val publisher = flow<Int> { in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublishTest.kt | 21 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
39 val publisher = publish(currentDispatcher()) { in <lambda>() constant
65 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
96 val publisher = publish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
133 val publisher = publish<Int>(Dispatchers.Unconfined) { in <lambda>() constant
153 val publisher = publish(currentDispatcher() + exceptionHandler) { in <lambda>() constant
198 val publisher = publish<Int>(handler + Dispatchers.Unconfined) { in <lambda>() constant
262 val publisher = publish<Int>(Dispatchers.Unconfined) { in <lambda>() constant
282 val publisher = publish { in <lambda>() constant
|
| D | PublisherAsFlowTest.kt | 20 val publisher = publish(currentDispatcher()) { in <lambda>() constant
48 val publisher = publish(currentDispatcher()) { in <lambda>() constant
69 val publisher = publish(currentDispatcher()) { in <lambda>() constant
86 val publisher = publish(currentDispatcher()) { in <lambda>() constant
105 val publisher = publish(currentDispatcher()) { in <lambda>() constant
126 val publisher = publish(currentDispatcher()) { in <lambda>() constant
233 val publisher = Publisher<Int> { s -> in <lambda>() constant
|
| D | PublisherCollectTest.kt | 19 val publisher = Publisher<Int> { subscriber -> in <lambda>() constant
60 val publisher = Publisher<Int> { subscriber -> in <lambda>() constant
102 val publisher = Publisher<Int> { subscriber -> in <lambda>() constant
|
| D | IterableFlowTckTest.kt | 52 val publisher = array.asIterable().asFlow().asPublisher() in testStackOverflowTrampoline() constant
87 val publisher = array.asIterable().asFlow().asPublisher() in testConcurrentRequest() constant
|
| D | AwaitTest.kt | 18 val publisher = Publisher<Int> { s -> in <lambda>() constant
|
| D | FlowAsPublisherTest.kt | 156 val publisher = flow<Int> { in <lambda>() constant
|
| D | IntegrationTest.kt | 141 fun <T> publisher(block: Subscriber<in T>.(n: Long) -> Unit) = in <lambda>() method
215 val publisher = publish<Int> { in <lambda>() constant
|
| D | PublisherRequestStressTest.kt | 70 val publisher = mtFlow().asPublisher() in <lambda>() constant
|
| /external/openscreen/discovery/dnssd/impl/ |
| D | service_dispatcher.cc | 38 auto* publisher = service_instance->GetPublisher(); in ForAllPublishers() local
112 auto register_instance = [&instance, client](DnsSdPublisher* publisher) { in Register()
121 auto update_registration = [&instance](DnsSdPublisher* publisher) { in UpdateRegistration()
133 auto* publisher = service_instance->GetPublisher(); in DeregisterAll() local
|
| D | publisher_impl_unittest.cc | 69 PublisherImpl* publisher() { return &publisher_; } in publisher() function in openscreen::discovery::__anonbc05ed430111::PublisherImplTest
|
| D | publisher_impl.cc | 84 PublisherImpl::PublisherImpl(MdnsService* publisher, in PublisherImpl()
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_publisher.cc | 84 for (const RecordAnnouncerPtr& publisher : it->second) { in RegisterRecord() local
222 [&record](const RecordAnnouncerPtr& publisher) { in RemoveRecord()
250 MdnsPublisher* publisher, in RecordAnnouncer()
|
| /external/openscreen/osp/impl/ |
| D | service_publisher_impl.cc | 43 ServicePublisherImpl* publisher) { in SetPublisherImpl()
|
| /external/swiftshader/third_party/SPIRV-Tools/utils/vscode/ |
| D | package.json | 8 "publisher": "Google", string
|
| /external/deqp-deps/SPIRV-Tools/utils/vscode/ |
| D | package.json | 8 "publisher": "Google", string
|
| /external/angle/third_party/vulkan-deps/spirv-tools/src/utils/vscode/ |
| D | package.json | 8 "publisher": "Google", string
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 49 private val publisher: Publisher<T>, in <lambda>() constant in kotlinx.coroutines.reactive.PublisherAsFlow
|
| /external/protobuf/src/google/protobuf/util/internal/testdata/ |
| D | books.proto | 62 optional Publisher publisher = 9; field
|
| /external/protobuf/src/google/protobuf/util/internal/ |
| D | protostream_objectwriter_test.cc | 218 Publisher* publisher = book.mutable_publisher(); in TEST_P() local
709 Publisher* publisher = expected.mutable_publisher(); in TEST_P() local
868 Publisher* publisher = expected.mutable_publisher(); in TEST_P() local
980 Publisher* publisher = expected.mutable_publisher(); in TEST_P() local
|
| /external/openscreen/osp/demo/ |
| D | osp_demo.cc | 462 ServicePublisher* publisher = manager->GetServicePublisher(); in HandleReceiverCommand() local
|