| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | client_unary_unary_interceptor_test.py | 58 async def intercept_unary_unary(self, continuation, argument
101 async def intercept_unary_unary(self, continuation, argument
130 async def intercept_unary_unary(self, continuation, argument
171 async def intercept_unary_unary(self, continuation, argument
229 async def intercept_unary_unary(self, continuation, argument
239 async def intercept_unary_unary(self, continuation, argument
284 async def intercept_unary_unary(self, continuation, argument
312 async def intercept_unary_unary(self, continuation, argument
341 async def intercept_unary_unary(self, continuation, argument
374 async def intercept_unary_unary(self, continuation, argument
[all …]
|
| D | client_unary_stream_interceptor_test.py | 40 async def intercept_unary_stream(self, continuation, client_call_details, argument
51 async def intercept_unary_stream(self, continuation, client_call_details, argument
259 async def intercept_unary_stream(self, continuation, argument
294 async def intercept_unary_stream(self, continuation, argument
348 async def intercept_unary_stream(self, continuation, argument
376 async def intercept_unary_stream(self, continuation, argument
|
| D | client_stream_unary_interceptor_test.py | 39 async def intercept_stream_unary(self, continuation, client_call_details, argument
50 async def intercept_stream_unary(self, continuation, client_call_details, argument
316 async def intercept_stream_unary(self, continuation, argument
359 async def intercept_stream_unary(self, continuation, argument
433 async def intercept_stream_unary(self, continuation, argument
469 async def intercept_stream_unary(self, continuation, argument
|
| D | client_stream_stream_interceptor_test.py | 32 async def intercept_stream_stream(self, continuation, client_call_details, argument
43 async def intercept_stream_stream(self, continuation, client_call_details, argument
|
| /third_party/boost/boost/thread/executors/ |
| D | serial_executor_cont.hpp | 45 struct continuation { struct in boost::executors::serial_executor_cont
46 work task;
48 struct result {
51 continuation(BOOST_THREAD_RV_REF(work) tsk) in continuation() argument
53 void operator()(BOOST_THREAD_FUTURE<void> f) in operator ()()
|
| /third_party/grpc/examples/python/interceptors/headers/ |
| D | generic_client_interceptor.py | 27 def intercept_unary_unary(self, continuation, client_call_details, request): argument
33 def intercept_unary_stream(self, continuation, client_call_details, argument
40 def intercept_stream_unary(self, continuation, client_call_details, argument
47 def intercept_stream_stream(self, continuation, client_call_details, argument
|
| D | request_header_validator_interceptor.py | 34 def intercept_service(self, continuation, handler_call_details): argument
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ClientInterceptorTest.cs | 142 …text<TRequest, TResponse> context, BlockingUnaryCallContinuation<TRequest, TResponse> continuation) in BlockingUnaryCall()
148 …Context<TRequest, TResponse> context, AsyncUnaryCallContinuation<TRequest, TResponse> continuation) in AsyncUnaryCall()
154 …equest, TResponse> context, AsyncServerStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncServerStreamingCall()
160 …equest, TResponse> context, AsyncClientStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncClientStreamingCall()
166 …equest, TResponse> context, AsyncDuplexStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncDuplexStreamingCall()
175 …equest, TResponse> context, AsyncClientStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncClientStreamingCall()
|
| D | ServerInterceptorTest.cs | 148 …>(TRequest request, ServerCallContext context, UnaryServerMethod<TRequest, TResponse> continuation) in UnaryServerHandler()
154 …stStream, ServerCallContext context, ClientStreamingServerMethod<TRequest, TResponse> continuation) in ClientStreamingServerHandler()
160 …seStream, ServerCallContext context, ServerStreamingServerMethod<TRequest, TResponse> continuation) in ServerStreamingServerHandler()
166 …seStream, ServerCallContext context, DuplexStreamingServerMethod<TRequest, TResponse> continuation) in DuplexStreamingServerHandler()
|
| /third_party/grpc/src/php/lib/Grpc/ |
| D | Interceptor.php | 34 $continuation,
44 $continuation,
55 $continuation,
65 $continuation,
|
| /third_party/grpc/src/php/tests/unit_tests/ |
| D | InterceptorTest.php | 99 $continuation,
108 $continuation,
122 $continuation,
135 $continuation,
178 $continuation,
187 $continuation,
202 $continuation,
210 $continuation,
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/ |
| D | CallInvokerExtensions.cs | 117 …text<TRequest, TResponse> context, BlockingUnaryCallContinuation<TRequest, TResponse> continuation) in BlockingUnaryCall()
122 …Context<TRequest, TResponse> context, AsyncUnaryCallContinuation<TRequest, TResponse> continuation) in AsyncUnaryCall()
127 …equest, TResponse> context, AsyncServerStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncServerStreamingCall()
132 …equest, TResponse> context, AsyncClientStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncClientStreamingCall()
137 …equest, TResponse> context, AsyncDuplexStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncDuplexStreamingCall()
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _interceptor_test.py | 206 def intercept_unary_unary(self, continuation, client_call_details, request): argument
212 def intercept_unary_stream(self, continuation, client_call_details, argument
219 def intercept_stream_unary(self, continuation, client_call_details, argument
226 def intercept_stream_stream(self, continuation, client_call_details, argument
244 def intercept_service(self, continuation, handler_call_details): argument
248 def intercept_unary_unary(self, continuation, client_call_details, request): argument
261 def intercept_unary_stream(self, continuation, client_call_details, argument
266 def intercept_stream_unary(self, continuation, client_call_details, argument
278 def intercept_stream_stream(self, continuation, client_call_details, argument
327 def intercept_service(self, continuation, handler_call_details): argument
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | ClientBase.cs | 172 …text<TRequest, TResponse> context, BlockingUnaryCallContinuation<TRequest, TResponse> continuation) in BlockingUnaryCall()
177 …Context<TRequest, TResponse> context, AsyncUnaryCallContinuation<TRequest, TResponse> continuation) in AsyncUnaryCall()
182 …equest, TResponse> context, AsyncServerStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncServerStreamingCall()
187 …equest, TResponse> context, AsyncClientStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncClientStreamingCall()
192 …equest, TResponse> context, AsyncDuplexStreamingCallContinuation<TRequest, TResponse> continuation) in AsyncDuplexStreamingCall()
|
| /third_party/grpc/examples/python/interceptors/default_value/ |
| D | default_value_client_interceptor.py | 55 def _intercept_call(self, continuation, client_call_details, argument
60 def intercept_unary_unary(self, continuation, client_call_details, request): argument
63 def intercept_stream_unary(self, continuation, client_call_details, argument
|
| /third_party/boost/boost/context/ |
| D | continuation_fcontext.hpp | 204 class continuation { class
223 continuation( detail::fcontext_t fctx) noexcept : in continuation() function in boost::context::continuation
243 continuation( continuation && other) noexcept { in continuation() function in boost::context::continuation
|
| D | continuation_winfib.hpp | 293 class BOOST_CONTEXT_DECL continuation { class
316 continuation( detail::activation_record * ptr) noexcept : in continuation() function in boost::context::continuation
337 continuation( continuation && other) noexcept { in continuation() function in boost::context::continuation
|
| D | continuation_ucontext.hpp | 358 class BOOST_CONTEXT_DECL continuation { class
381 continuation( detail::activation_record * ptr) noexcept : in continuation() function in boost::context::continuation
402 continuation( continuation && other) noexcept { in continuation() function in boost::context::continuation
|
| /third_party/grpc/examples/python/auth/ |
| D | customized_auth_server.py | 46 def intercept_service(self, continuation, handler_call_details): argument
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 235 def continuation(new_details, request): function
284 def continuation(new_details, request): function
322 def continuation(new_details, request): function
374 def continuation(new_details, request_iterator): function
423 def continuation(new_details, request_iterator): function
461 def continuation(new_details, request_iterator): function
|
| /third_party/flutter/engine/flutter/shell/common/ |
| D | pipeline_unittests.cc | 23 Continuation continuation = pipeline->Produce(); in TEST() local
37 Continuation continuation = pipeline->Produce(); in TEST() local
|
| D | pipeline.h | 81 ProducerContinuation(Continuation continuation, size_t trace_id) in ProducerContinuation()
|
| /third_party/uboot/u-boot-2020.01/arch/x86/include/asm/fsp1/ |
| D | fsp_api.h | 34 fsp_continuation_f continuation; member
|
| /third_party/boost/boost/asio/execution/ |
| D | relationship.hpp | 121 static constexpr continuation_t continuation; member
|
| /third_party/ffmpeg/libavformat/ |
| D | rtpdec_mpa_robust.c | 71 unsigned adu_size, continuation; in mpa_robust_parse_packet() local
|