| /external/clang/tools/scan-build-py/libscanbuild/ |
| D | runner.py | 156 def run_analyzer(opts, continuation=report_failure): argument
198 def filter_debug_flags(opts, continuation=run_analyzer): argument
209 def set_file_path_relative(opts, continuation=filter_debug_flags): argument
220 def language_check(opts, continuation=set_file_path_relative): argument
250 def arch_check(opts, continuation=language_check): argument
|
| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | generic_client_interceptor.py | 26 def intercept_unary_unary(self, continuation, client_call_details, request): argument
32 def intercept_unary_stream(self, continuation, client_call_details, argument
39 def intercept_stream_unary(self, continuation, client_call_details, argument
46 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
|
| /external/grpc-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 | 101 …>(TRequest request, ServerCallContext context, UnaryServerMethod<TRequest, TResponse> continuation) in UnaryServerHandler()
107 …stStream, ServerCallContext context, ClientStreamingServerMethod<TRequest, TResponse> continuation) in ClientStreamingServerHandler()
113 …seStream, ServerCallContext context, ServerStreamingServerMethod<TRequest, TResponse> continuation) in ServerStreamingServerHandler()
119 …seStream, ServerCallContext context, DuplexStreamingServerMethod<TRequest, TResponse> continuation) in DuplexStreamingServerHandler()
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| D | InterceptorTest.php | 101 $continuation)
106 …terceptStreamUnary($method, $deserialize, array $metadata = [], array $options = [], $continuation)
120 $continuation)
133 $continuation)
176 $continuation)
181 …terceptStreamUnary($method, $deserialize, array $metadata = [], array $options = [], $continuation)
195 $continuation)
202 $continuation)
|
| /external/grpc-grpc/src/csharp/Grpc.Core/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()
|
| /external/grpc-grpc/src/php/lib/Grpc/ |
| D | Interceptor.php | 36 $continuation
46 $continuation
57 $continuation
67 $continuation
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _interceptor_test.py | 191 def intercept_unary_unary(self, continuation, client_call_details, request): argument
197 def intercept_unary_stream(self, continuation, client_call_details, argument
204 def intercept_stream_unary(self, continuation, client_call_details, argument
211 def intercept_stream_stream(self, continuation, client_call_details, argument
228 def intercept_service(self, continuation, handler_call_details): argument
232 def intercept_unary_unary(self, continuation, client_call_details, request): argument
236 def intercept_unary_stream(self, continuation, client_call_details, argument
241 def intercept_stream_unary(self, continuation, client_call_details, argument
246 def intercept_stream_stream(self, continuation, client_call_details, argument
295 def intercept_service(self, continuation, handler_call_details): argument
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CancellableContinuationTest.kt | 14 var continuation: Continuation<Unit>? = null in <lambda>() variable
36 var continuation: Continuation<Unit>? = null in <lambda>() variable
54 var continuation: Continuation<Unit>? = null in <lambda>() variable
76 var continuation: Continuation<Unit>? = null in <lambda>() variable
101 var continuation: Continuation<Unit>? = null in <lambda>() variable
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| 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()
|
| /external/llvm-project/clang/tools/scan-build-py/libscanbuild/ |
| D | analyze.py | 524 def run_analyzer(opts, continuation=report_failure): argument
643 def dispatch_ctu(opts, continuation=run_analyzer): argument
667 def filter_debug_flags(opts, continuation=dispatch_ctu): argument
678 def language_check(opts, continuation=filter_debug_flags): argument
708 def arch_check(opts, continuation=language_check): argument
|
| /external/grpc-grpc/examples/python/interceptors/default_value/ |
| D | default_value_client_interceptor.py | 57 def _intercept_call(self, continuation, client_call_details, argument
62 def intercept_unary_unary(self, continuation, client_call_details, request): argument
65 def intercept_stream_unary(self, continuation, client_call_details, argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Builders.common.kt | 111 private val continuation = block.createCoroutineUnintercepted(this, this) in getCompleted() constant
198 private val continuation = block.createCoroutineUnintercepted(this, this) constant
|
| D | Await.kt | 104 …private inner class AwaitAllNode(private val continuation: CancellableContinuation<List<T>>, job: … in toString() constant in kotlinx.coroutines.AwaitAll.AwaitAllNode
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 151 private var continuation = block.createCoroutineUnintercepted(this, this) variable
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Broadcast.kt | 174 private val continuation = block.createCoroutineUnintercepted(this, this) constant
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 209 def continuation(new_details, request): function
239 def continuation(new_details, request): function
266 def continuation(new_details, request): function
309 def continuation(new_details, request_iterator): function
347 def continuation(new_details, request_iterator): function
378 def continuation(new_details, request_iterator): function
|
| D | __init__.py | 370 def intercept_unary_unary(self, continuation, client_call_details, request): argument
407 def intercept_unary_stream(self, continuation, client_call_details, argument
443 def intercept_stream_unary(self, continuation, client_call_details, argument
481 def intercept_stream_stream(self, continuation, client_call_details, argument
1169 def intercept_service(self, continuation, handler_call_details): argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | DispatchedTask.kt | 87 val continuation = delegate.continuation in getSuccessfulResult() constant
|
| D | DispatchedContinuation.kt | 21 @JvmField val continuation: Continuation<T> in <lambda>() constant in kotlinx.coroutines.internal.DispatchedContinuation
|
| /external/llvm-project/mlir/lib/Conversion/SCFToStandard/ |
| D | SCFToStandard.cpp | 487 Block *continuation = in matchAndRewrite() local
545 Block *continuation = in matchAndRewrite() local
|
| /external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/ |
| D | LockFreedomTestEnvironment.kt | 319 private var continuation: Continuation<Any?>? = null in <lambda>() variable in kotlinx.atomicfu.LockFreedomTestEnvironment
326 val continuation = takeContinuation() in <lambda>() constant
|
| /external/lottie/LottieSample/src/androidTest/java/com/airbnb/lottie/samples/ |
| D | Utils.kt | 38 suspend fun TransferObserver.await() = suspendCoroutine<TransferObserver> { continuation -> in await() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 158 private val continuation: CancellableContinuation<Unit> in toString() constant in kotlinx.coroutines.ResumeUndispatchedRunnable
|