Home
last modified time | relevance | path

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

1234

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/
DREADME.md1 # Module kotlinx-coroutines-reactor
30 | [Scheduler.asCoroutineDispatcher][reactor.core.scheduler.Scheduler.asCoroutineDispatcher] | Conve…
43 <!--- MODULE kotlinx-coroutines-reactor -->
44 <!--- INDEX kotlinx.coroutines.reactor -->
46 …//kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/mono…
47 …//kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/flux…
48 …//kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-f…
49 …tlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/-reactor…
50 …//kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-m…
51 …//kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-m…
[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.h161 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor() argument
162 reactor->BindStream(this); in BindReactor()
176 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor() argument
177 reactor->BindReader(this); in BindReactor()
197 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor() argument
198 reactor->BindWriter(this); in BindReactor()
208 void BindReactor(ClientUnaryReactor* reactor);
446 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor() argument
447 reactor->BindCall(this); in BindReactor()
585 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl() argument
[all …]
Dserver_callback.h95 ScheduleOnDone(reactor()->InternalInlineable()); in MaybeDone()
107 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel() argument
109 CallOnCancel(reactor); in MaybeCallOnCancel()
119 CallOnCancel(reactor()); in MaybeCallOnCancel()
128 virtual ServerReactor* reactor() = 0;
141 void CallOnCancel(ServerReactor* reactor);
202 void BindReactor(Reactor* reactor) { in BindReactor() argument
203 reactor->InternalBindCall(this); in BindReactor()
216 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor() argument
217 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.h161 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor() argument
162 reactor->BindStream(this); in BindReactor()
176 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor() argument
177 reactor->BindReader(this); in BindReactor()
197 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor() argument
198 reactor->BindWriter(this); in BindReactor()
208 void BindReactor(ClientUnaryReactor* reactor);
446 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor() argument
447 reactor->BindCall(this); in BindReactor()
585 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl() argument
[all …]
Dserver_callback.h95 ScheduleOnDone(reactor()->InternalInlineable()); in MaybeDone()
107 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel() argument
109 CallOnCancel(reactor); in MaybeCallOnCancel()
119 CallOnCancel(reactor()); in MaybeCallOnCancel()
128 virtual ServerReactor* reactor() = 0;
141 void CallOnCancel(ServerReactor* reactor);
202 void BindReactor(Reactor* reactor) { in BindReactor() argument
203 reactor->InternalBindCall(this); in BindReactor()
216 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor() argument
217 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/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h106 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
108 reactor); in PrepareUnaryCall()
116 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
117 PrepareBidiStreamingCallInternal(context, method, /*options=*/{}, reactor); in PrepareBidiStreamingCall()
144 ResponseType* response, ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
146 response, reactor); in PrepareUnaryCall()
154 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
156 reactor); in PrepareBidiStreamingCall()
186 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal() argument
191 context, request, response, reactor); in PrepareUnaryCallInternal()
[all …]
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h106 ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
108 reactor); in PrepareUnaryCall()
116 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
117 PrepareBidiStreamingCallInternal(context, method, /*options=*/{}, reactor); in PrepareBidiStreamingCall()
144 ResponseType* response, ClientUnaryReactor* reactor) { in PrepareUnaryCall() argument
146 response, reactor); in PrepareUnaryCall()
154 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
156 reactor); in PrepareBidiStreamingCall()
186 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal() argument
191 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 {
33 public final class kotlinx/coroutines/reactor/ReactorContext : kotlin/coroutines/AbstractCoroutineC…
34 public static final field Key Lkotlinx/coroutines/reactor/ReactorContext$Key;
41 public final class kotlinx/coroutines/reactor/ReactorContext$Key : kotlin/coroutines/CoroutineConte…
44 public final class kotlinx/coroutines/reactor/ReactorContextKt {
45 … fun asCoroutineContext (Lreactor/util/context/Context;)Lkotlinx/coroutines/reactor/ReactorContext;
46 … asCoroutineContext (Lreactor/util/context/ContextView;)Lkotlinx/coroutines/reactor/ReactorContext;
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
Dmodule-info.java2 import kotlinx.coroutines.reactor.ReactorContextInjector;
4 module kotlinx.coroutines.reactor {
9 requires reactor.core;
11 exports kotlinx.coroutines.reactor;
DReactorContextInjector.kt5 package kotlinx.coroutines.reactor
9 import reactor.core.publisher.*
10 import reactor.util.context.*
DFlux.kt5 package kotlinx.coroutines.reactor in <lambda>()
11 import reactor.core.* in <lambda>()
12 import reactor.core.publisher.* in <lambda>()
13 import reactor.util.context.* in <lambda>()
DReactorFlow.kt5 package kotlinx.coroutines.reactor
12 import reactor.core.CoreSubscriber
13 import reactor.core.publisher.Flux
/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/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/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/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/
DMonoAwaitStressTest.kt5 package kotlinx.coroutines.reactor
10 import reactor.core.*
11 import reactor.core.publisher.*
DCheck.kt5 package kotlinx.coroutines.reactor
7 import reactor.core.publisher.Flux
8 import reactor.core.publisher.Mono

1234