| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherAsFlowTest.kt | 19 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
29 publisher.asFlow().launchIn(CoroutineScope(Dispatchers.Unconfined)) { in <lambda>()
47 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
59 publisher.asFlow().buffer(1).collect { in <lambda>()
68 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
76 publisher.asFlow().collect { in <lambda>()
85 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
95 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
104 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
116 publisher.asFlow().buffer(10).collect { in <lambda>()
[all …]
|
| D | PublishTest.kt | 16 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
20 publisher.subscribe(object : JFlow.Subscriber<Int> { in <lambda>()
34 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
40 publisher.subscribe(object : JFlow.Subscriber<Int> { in <lambda>()
60 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>() constant
65 publisher.subscribe(object : JFlow.Subscriber<Int> { in <lambda>()
91 val publisher = flowPublish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
101 publisher.subscribe(object : JFlow.Subscriber<Unit> { in <lambda>()
127 val publisher = flowPublish(currentDispatcher()) { in <lambda>() constant
138 publisher.subscribe(object : JFlow.Subscriber<String> { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | ReactorContextInjector.kt | 9 import reactor.core.publisher.*
18 …override fun <T> injectCoroutineContext(publisher: Publisher<T>, coroutineContext: CoroutineContex… in injectCoroutineContext()
19 val reactorContext = coroutineContext[ReactorContext]?.context ?: return publisher in injectCoroutineContext()
20 return when(publisher) { in injectCoroutineContext()
21 is Mono -> publisher.subscriberContext(reactorContext) in injectCoroutineContext()
22 is Flux -> publisher.subscriberContext(reactorContext) in injectCoroutineContext()
23 else -> publisher in injectCoroutineContext()
|
| D | Migration.kt | 10 import reactor.core.publisher.*
|
| D | Convert.kt | 9 import reactor.core.publisher.*
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/ |
| D | README.md | 9 … | `Publisher` | [ProducerScope] | Cold reactive publisher that starts the …
15 | [Publisher.asFlow] | `Flow` | Converts the given publisher to a flow
16 | [Flow.asPublisher] | `Publisher` | Converts the given flow to a TCK-compliant publisher
25 …First][org.reactivestreams.Publisher.awaitFirst] | Returns the first value from the given publisher
26 …treams.Publisher.awaitFirstOrDefault] | Returns the first value from the given publisher or default
27 …ms.Publisher.awaitFirstOrElse] | Returns the first value from the given publisher or default from …
28 …ctivestreams.Publisher.awaitFirstOrNull] | Returns the first value from the given publisher or null
29 …itLast][org.reactivestreams.Publisher.awaitFirst] | Returns the last value from the given publisher
30 …gle][org.reactivestreams.Publisher.awaitSingle] | Returns the single value from the given publisher
41 …kotlinx-coroutines-reactive/kotlinx.coroutines.reactive/org.reactivestreams.-publisher/as-flow.html
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 20 val publisher = publish(currentDispatcher()) { in <lambda>() constant
30 publisher.asFlow().launchIn(CoroutineScope(Dispatchers.Unconfined)) { in <lambda>()
48 val publisher = publish(currentDispatcher()) { in <lambda>() constant
60 publisher.asFlow().buffer(1).collect { in <lambda>()
69 val publisher = publish(currentDispatcher()) { in <lambda>() constant
77 publisher.asFlow().collect { in <lambda>()
86 val publisher = publish(currentDispatcher()) { in <lambda>() constant
96 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
105 val publisher = publish(currentDispatcher()) { in <lambda>() constant
117 publisher.asFlow().buffer(10).collect { in <lambda>()
[all …]
|
| D | PublishTest.kt | 16 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
20 publisher.subscribe(object : Subscriber<Int> { in <lambda>()
34 val publisher = publish(currentDispatcher()) { in <lambda>() constant
40 publisher.subscribe(object : Subscriber<Int> { in <lambda>()
60 val publisher = publish<Int>(currentDispatcher()) { in <lambda>() constant
65 publisher.subscribe(object : Subscriber<Int> { in <lambda>()
91 val publisher = publish<Unit>(Dispatchers.Unconfined + eh) { in <lambda>() constant
101 publisher.subscribe(object : Subscriber<Unit> { in <lambda>()
127 val publisher = publish(currentDispatcher()) { in <lambda>() constant
138 publisher.subscribe(object : Subscriber<String> { in <lambda>()
|
| D | IterableFlowTckTest.kt | 58 val publisher = array.asIterable().asFlow().asPublisher() in testStackOverflowTrampoline() constant
60 publisher.subscribe(object : Subscriber<Long> { in testStackOverflowTrampoline()
93 val publisher = array.asIterable().asFlow().asPublisher() in testConcurrentRequest() constant
95 publisher.subscribe(object : Subscriber<Long> { in testConcurrentRequest()
|
| D | PublisherRequestStressTest.kt | 70 val publisher = mtFlow().asPublisher() in <lambda>() constant
73 publisher.subscribe(object : Subscriber<Long> { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/ |
| D | kotlinx-coroutines-reactor.api | 2 …routines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Flux;
3 …eceiveChannel;Lkotlin/coroutines/CoroutineContext;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
4 …no (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Mono;
5 … asMono (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext;)Lreactor/core/publisher/Mono;
9 public static final fun asFlux (Lkotlinx/coroutines/flow/Flow;)Lreactor/core/publisher/Flux;
13 …(Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lreactor/core/publisher/Flux;
14 …;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lreactor/core/publisher/Flux;
15 …/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
16 …/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lreactor/core/publisher/Flux;
20 …(Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lreactor/core/publisher/Mono;
[all …]
|
| /external/openscreen/discovery/dnssd/impl/ |
| D | service_dispatcher.cc | 38 auto* publisher = service_instance->GetPublisher(); in ForAllPublishers() local
39 OSP_CHECK(publisher); in ForAllPublishers()
42 Error inner_result = action(publisher); in ForAllPublishers()
112 auto register_instance = [&instance, client](DnsSdPublisher* publisher) { in Register() argument
113 return publisher->Register(instance, client); in Register()
121 auto update_registration = [&instance](DnsSdPublisher* publisher) { in UpdateRegistration() argument
122 return publisher->UpdateRegistration(instance); in UpdateRegistration()
133 auto* publisher = service_instance->GetPublisher(); in DeregisterAll() local
134 OSP_CHECK(publisher); in DeregisterAll()
137 auto result = publisher->DeregisterAll(service); in DeregisterAll()
|
| D | publisher_impl_unittest.cc | 69 PublisherImpl* publisher() { return &publisher_; } in publisher() function in openscreen::discovery::__anon46c0891e0111::PublisherImplTest
96 EXPECT_CALL(*mdns_service(), StartProbe(publisher(), domain, _)).Times(1); in TEST_F()
97 publisher()->Register(instance, &client); in TEST_F()
152 publisher()->DeregisterAll("_service._udp"); in TEST_F()
167 EXPECT_FALSE(publisher()->UpdateRegistration(instance).ok()); in TEST_F()
170 EXPECT_CALL(*mdns_service(), StartProbe(publisher(), domain, _)).Times(1); in TEST_F()
171 EXPECT_EQ(publisher()->Register(instance, &client), Error::None()); in TEST_F()
181 EXPECT_EQ(publisher()->UpdateRegistration(instance2), Error::None()); in TEST_F()
223 EXPECT_EQ(publisher()->UpdateRegistration(instance), Error::None()); in TEST_F()
|
| /external/apache-commons-bcel/docs/ |
| D | manual.bib | 40 publisher = {Springer},
83 publisher = {Addison-Wesley},
99 publisher = {Addison-Wesley},
115 publisher = {O'Reilly},
124 publisher = {Springer},
139 publisher = {Addison-Wesley},
154 publisher = {Springer},
170 publisher = {Springer},
180 publisher = {Springer},
|
| /external/llvm-project/polly/lib/External/isl/doc/ |
| D | isl.bib | 17 publisher = {Springer},
34 publisher = {Springer-Verlag},
41 publisher = "John Wiley \& Sons",
50 publisher = {SIAM},
92 publisher = {Kluwer Academic Publishers},
158 publisher = "Springer-Verlag",
173 publisher = {ACM},
243 publisher = {M{\"{a}}lardalen University Press},
296 publisher={Springer-Verlag},
363 publisher = "Springer",
[all …]
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_publisher.cc | 84 for (const RecordAnnouncerPtr& publisher : it->second) { in RegisterRecord() local
85 if (publisher->record() == record) { in RegisterRecord()
222 [&record](const RecordAnnouncerPtr& publisher) { in RemoveRecord() argument
223 return publisher->record() == record; in RemoveRecord()
250 MdnsPublisher* publisher, in RecordAnnouncer() argument
254 : publisher_(publisher), in RecordAnnouncer()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | Check.kt | 7 import reactor.core.publisher.Flux
8 import reactor.core.publisher.Mono
|
| D | FluxContextTest.kt | 12 import reactor.core.publisher.*
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-broker/ |
| D | README.md | 20 and a publisher mode ws connection back to the broker.
25 is passed to the broker on the publisher ws connection and
|
| /external/openscreen/osp/impl/ |
| D | service_publisher_impl.cc | 41 ServicePublisherImpl* publisher) { in SetPublisherImpl() argument
43 publisher_ = publisher; in SetPublisherImpl()
|
| D | internal_services.cc | 82 auto publisher = std::make_unique<ServicePublisherImpl>( in CreatePublisher() local
84 publisher->SetDestructionCallback(&InternalServices::DereferenceSingleton, in CreatePublisher()
86 return publisher; in CreatePublisher()
|
| /external/dtc/Documentation/ |
| D | dtc-paper.bib | 7 publisher = pub-IEEE,
16 publisher = pub-IEEE,
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 48 private val publisher: Publisher<T>, in <lambda>() constant in kotlinx.coroutines.reactive.PublisherAsFlow
54 PublisherAsFlow(publisher, context, capacity, onBufferOverflow) in <lambda>()
93 publisher.injectCoroutineContext(injectContext).subscribe(subscriber) in <lambda>()
|
| D | ContextInjector.kt | 18 …public fun <T> injectCoroutineContext(publisher: Publisher<T>, coroutineContext: CoroutineContext)…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/ |
| D | package.list | 3 reactor.core.publisher
|