Home
last modified time | relevance | path

Searched refs:reactor (Results 1 – 25 of 77) sorted by relevance

1234

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/
DREADME.md1 # Module kotlinx-coroutines-reactor
31 | [Scheduler.asCoroutineDispatcher][reactor.core.scheduler.Scheduler.asCoroutineDispatcher] | Conve…
40 <!--- MODULE kotlinx-coroutines-reactor -->
41 <!--- INDEX kotlinx.coroutines.reactor -->
42 …s://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/mono…
43 …s://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/flux…
44 …s://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/kotl…
45 …kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/-reactor…
46 …s://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/kotl…
47 …s://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/kotl…
[all …]
Dpackage.list1 reactor.adapter
2 reactor.core
3 reactor.core.publisher
4 reactor.core.scheduler
5 reactor.util
6 reactor.util.annotation
7 reactor.util.concurrent
8 reactor.util.context
9 reactor.util.function
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dserver_callback_handlers.h60 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
62 reactor = ::grpc::internal::CatchingReactorGetter<ServerUnaryReactor>( in RunHandler()
68 if (reactor == nullptr) { in RunHandler()
70 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
77 call->SetupReactor(reactor); in RunHandler()
163 ServerUnaryReactor* reactor = in SendInitialMetadata()
165 reactor->OnSendInitialMetadataDone(ok); in SendInitialMetadata()
198 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor() argument
199 reactor_.store(reactor, std::memory_order_relaxed); in SetupReactor()
200 this->BindReactor(reactor); in SetupReactor()
[all …]
Dclient_callback.h158 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor() argument
159 reactor->BindStream(this); in BindReactor()
173 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor() argument
174 reactor->BindReader(this); in BindReactor()
194 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor() argument
195 reactor->BindWriter(this); in BindReactor()
205 void BindReactor(ClientUnaryReactor* reactor);
446 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor() argument
447 reactor->BindCall(this); in BindReactor()
584 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl() argument
[all …]
Dserver_callback.h94 ScheduleOnDone(reactor()->InternalInlineable()); in MaybeDone()
106 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel() argument
108 CallOnCancel(reactor); in MaybeCallOnCancel()
118 CallOnCancel(reactor()); in MaybeCallOnCancel()
127 virtual ServerReactor* reactor() = 0;
140 void CallOnCancel(ServerReactor* reactor);
201 void BindReactor(Reactor* reactor) { in BindReactor() argument
202 reactor->InternalBindCall(this); in BindReactor()
215 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor() argument
216 reactor->InternalBindReader(this); in BindReactor()
[all …]
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dserver_callback_handlers.h60 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
62 reactor = ::grpc::internal::CatchingReactorGetter<ServerUnaryReactor>( in RunHandler()
68 if (reactor == nullptr) { in RunHandler()
70 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
77 call->SetupReactor(reactor); in RunHandler()
163 ServerUnaryReactor* reactor = in SendInitialMetadata()
165 reactor->OnSendInitialMetadataDone(ok); in SendInitialMetadata()
198 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor() argument
199 reactor_.store(reactor, std::memory_order_relaxed); in SetupReactor()
200 this->BindReactor(reactor); in SetupReactor()
[all …]
Dclient_callback.h158 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor() argument
159 reactor->BindStream(this); in BindReactor()
173 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor() argument
174 reactor->BindReader(this); in BindReactor()
194 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor() argument
195 reactor->BindWriter(this); in BindReactor()
205 void BindReactor(ClientUnaryReactor* reactor);
446 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor() argument
447 reactor->BindCall(this); in BindReactor()
584 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl() argument
[all …]
Dserver_callback.h94 ScheduleOnDone(reactor()->InternalInlineable()); in MaybeDone()
106 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel() argument
108 CallOnCancel(reactor); in MaybeCallOnCancel()
118 CallOnCancel(reactor()); in MaybeCallOnCancel()
127 virtual ServerReactor* reactor() = 0;
140 void CallOnCancel(ServerReactor* reactor);
201 void BindReactor(Reactor* reactor) { in BindReactor() argument
202 reactor->InternalBindCall(this); in BindReactor()
215 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor() argument
216 reactor->InternalBindReader(this); in BindReactor()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_callback.cc53 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel() argument
54 if (reactor->InternalInlineable()) { in CallOnCancel()
55 reactor->OnCancel(); in CallOnCancel()
64 ServerReactor* reactor; in CallOnCancel() member
66 : call(call_arg), reactor(reactor_arg) { in CallOnCancel()
71 arg->reactor->OnCancel(); in CallOnCancel()
78 ClosureWithArg* arg = new ClosureWithArg(this, reactor); in CallOnCancel()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h102 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
103 PrepareUnaryCallInternal(context, method, request, response, reactor); in PrepareUnaryCall()
111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
112 PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
140 reactor); in PrepareUnaryCall()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
149 stub_->PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
178 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal() argument
183 context, request, response, reactor); in PrepareUnaryCallInternal()
[all …]
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h102 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
103 PrepareUnaryCallInternal(context, method, request, response, reactor); in PrepareUnaryCall()
111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
112 PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
140 reactor); in PrepareUnaryCall()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
149 stub_->PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
178 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal() argument
183 context, request, response, reactor); in PrepareUnaryCallInternal()
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/
Dkotlinx-coroutines-reactor.api1 public final class kotlinx/coroutines/reactor/ConvertKt {
8 public final class kotlinx/coroutines/reactor/FlowKt {
12 public final class kotlinx/coroutines/reactor/FluxKt {
19 public final class kotlinx/coroutines/reactor/MonoKt {
26 public final class kotlinx/coroutines/reactor/ReactorContext : kotlin/coroutines/AbstractCoroutineC…
27 public static final field Key Lkotlinx/coroutines/reactor/ReactorContext$Key;
32 public final class kotlinx/coroutines/reactor/ReactorContext$Key : kotlin/coroutines/CoroutineConte…
35 public final class kotlinx/coroutines/reactor/ReactorContextKt {
36 … fun asCoroutineContext (Lreactor/util/context/Context;)Lkotlinx/coroutines/reactor/ReactorContext;
39 public final class kotlinx/coroutines/reactor/ReactorFlowKt {
[all …]
/external/rust/crates/grpcio-sys/grpc/test/http2_test/
Dhttp2_test_server.py22 import twisted.internet.reactor
96 twisted.internet.reactor.stop()
109 twisted.internet.reactor, portnum, backlog=128)
111 twisted.internet.reactor.callWhenRunning(listen, endpoint, test_case)
123 twisted.internet.reactor.run()
/external/grpc-grpc/test/http2_test/
Dhttp2_test_server.py23 import twisted.internet.reactor
90 twisted.internet.reactor.stop()
101 twisted.internet.reactor, portnum, backlog=128)
103 twisted.internet.reactor.callWhenRunning(listen, endpoint, test_case)
113 twisted.internet.reactor.run()
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dreactive_socket_service_base.hpp55 reactor::per_descriptor_data reactor_data_;
210 start_op(impl, reactor::write_op, p.p, is_continuation, true, in async_send()
235 start_op(impl, reactor::write_op, p.p, is_continuation, false, false); in async_send()
283 ? reactor::except_op : reactor::read_op, in async_receive()
312 ? reactor::except_op : reactor::read_op, in async_receive()
369 ? reactor::except_op : reactor::read_op, in async_receive_with_flags()
400 ? reactor::except_op : reactor::read_op, in async_receive_with_flags()
430 reactor& reactor_;
Dreactor_fwd.hpp21 typedef class epoll_reactor reactor; typedef
23 typedef class dev_poll_reactor reactor;
25 typedef class select_reactor reactor;
/external/grpc-grpc/test/cpp/naming/utils/
Ddns_server.py28 import twisted.internet.reactor
106 twisted.internet.reactor.listenTCP(args.port, server)
109 twisted.internet.reactor.listenUDP(args.port, dns_proto)
112 twisted.internet.reactor.suggestThreadPoolSize(1)
113 twisted.internet.reactor.run()
117 twisted.internet.reactor.stop()
Ddns_resolver.py23 import twisted.internet.reactor as reactor namespace
41 def BeginQuery(reactor, qname): argument
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DReactorContextInjector.kt5 package kotlinx.coroutines.reactor
9 import reactor.core.publisher.*
10 import reactor.util.context.*
DFlux.kt8 package kotlinx.coroutines.reactor in <lambda>()
14 import reactor.core.* in <lambda>()
15 import reactor.core.publisher.* in <lambda>()
16 import reactor.util.context.* in <lambda>()
DReactorFlow.kt5 package kotlinx.coroutines.reactor
12 import reactor.core.CoreSubscriber
13 import reactor.core.publisher.Flux
DScheduler.kt5 package kotlinx.coroutines.reactor
8 import reactor.core.Disposable
9 import reactor.core.scheduler.Scheduler
DMono.kt7 package kotlinx.coroutines.reactor in <lambda>()
10 import reactor.core.* in <lambda>()
11 import reactor.core.publisher.* in <lambda>()
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/
Dclient_callback.cc33 ClientReactor* const reactor; in InternalScheduleOnDone() member
36 : reactor(reactor_arg), status(std::move(s)) { in InternalScheduleOnDone()
41 arg->reactor->OnDone(arg->status); in InternalScheduleOnDone()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DCheck.kt5 package kotlinx.coroutines.reactor
7 import reactor.core.publisher.Flux
8 import reactor.core.publisher.Mono

1234