Home
last modified time | relevance | path

Searched defs:publisher (Results 1 – 22 of 22) sorted by relevance

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/
DPublisherAsFlowTest.kt19 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
DPublishTest.kt16 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
34 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
60 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
91 val publisher = flowPublish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
127 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DPublishTest.kt16 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
34 val publisher = publish(currentDispatcher()) { in <lambda>() constant
60 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
91 val publisher = publish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
127 val publisher = publish(currentDispatcher()) { in <lambda>() constant
DPublisherAsFlowTest.kt20 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
DIterableFlowTckTest.kt58 val publisher = array.asIterable().asFlow().asPublisher() in testStackOverflowTrampoline() constant
93 val publisher = array.asIterable().asFlow().asPublisher() in testConcurrentRequest() constant
DPublisherRequestStressTest.kt70 val publisher = mtFlow().asPublisher() in <lambda>() constant
/external/openscreen/discovery/dnssd/impl/
Dservice_dispatcher.cc38 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
Dpublisher_impl_unittest.cc69 PublisherImpl* publisher() { return &publisher_; } in publisher() function in openscreen::discovery::__anon60c171970111::PublisherImplTest
Dpublisher_impl.cc84 PublisherImpl::PublisherImpl(MdnsService* publisher, in PublisherImpl()
/external/openscreen/discovery/mdns/
Dmdns_publisher.cc84 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/
Dservice_publisher_impl.cc41 ServicePublisherImpl* publisher) { in SetPublisherImpl()
Dinternal_services.cc82 auto publisher = std::make_unique<ServicePublisherImpl>( in CreatePublisher() local
/external/deqp-deps/SPIRV-Tools/utils/vscode/
Dpackage.json8 "publisher": "Google", string
/external/swiftshader/third_party/SPIRV-Tools/utils/vscode/
Dpackage.json8 "publisher": "Google", string
/external/llvm-project/llvm/utils/vscode/llvm/
Dpackage.json5 "publisher": "llvm-vs-code-extensions", string
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DReactiveFlow.kt48 private val publisher: Publisher<T>, in <lambda>() constant in kotlinx.coroutines.reactive.PublisherAsFlow
/external/protobuf/src/google/protobuf/util/internal/testdata/
Dbooks.proto62 optional Publisher publisher = 9; field
/external/protobuf/src/google/protobuf/util/internal/
Dprotostream_objectwriter_test.cc218 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/llvm-project/lldb/tools/lldb-vscode/
Dpackage.json5 "publisher": "llvm", string
/external/openscreen/osp/demo/
Dosp_demo.cc460 ServicePublisher* publisher = manager->GetMdnsServicePublisher(); in HandleReceiverCommand() local
/external/icu/tools/srcgen/currysrc/libs/
Dorg.eclipse.osgi_3.13.0.v20180409-1500.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSE_.SF META-INF/ECLIPSE_ ...
/external/kotlinc/lib/
Dkotlin-compiler.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/backend-common. ...