| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | header_manipulator_client_interceptor.py | 32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
35 if client_call_details.metadata is not None:
36 metadata = list(client_call_details.metadata)
41 client_call_details = _ClientCallDetails(
42 client_call_details.method, client_call_details.timeout, metadata,
43 client_call_details.credentials)
44 return client_call_details, request_iterator, None
|
| D | generic_client_interceptor.py | 26 def intercept_unary_unary(self, continuation, client_call_details, request): argument
28 client_call_details, iter((request,)), False, False)
32 def intercept_unary_stream(self, continuation, client_call_details, argument
35 client_call_details, iter((request,)), False, True)
39 def intercept_stream_unary(self, continuation, client_call_details, argument
42 client_call_details, request_iterator, True, False)
46 def intercept_stream_stream(self, continuation, client_call_details, argument
49 client_call_details, request_iterator, True, True)
|
| /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
193 client_call_details, iter((request,)), False, False)
197 def intercept_unary_stream(self, continuation, client_call_details, argument
200 client_call_details, iter((request,)), False, True)
204 def intercept_stream_unary(self, continuation, client_call_details, argument
207 client_call_details, request_iterator, True, False)
211 def intercept_stream_stream(self, continuation, client_call_details, argument
214 client_call_details, request_iterator, True, True)
232 def intercept_unary_unary(self, continuation, client_call_details, request): argument
234 return continuation(client_call_details, request)
[all …]
|
| /external/grpc-grpc/examples/python/interceptors/default_value/ |
| D | default_value_client_interceptor.py | 57 def _intercept_call(self, continuation, client_call_details, argument
59 response = continuation(client_call_details, request_or_iterator)
62 def intercept_unary_unary(self, continuation, client_call_details, request): argument
63 return self._intercept_call(continuation, client_call_details, request)
65 def intercept_stream_unary(self, continuation, client_call_details, argument
67 return self._intercept_call(continuation, client_call_details,
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 206 client_call_details = _ClientCallDetails(self._method, timeout,
211 _unwrap_client_call_details(new_details, client_call_details))
225 continuation, client_call_details, request)
236 client_call_details = _ClientCallDetails(self._method, timeout,
241 _unwrap_client_call_details(new_details, client_call_details))
250 continuation, client_call_details, request)
263 client_call_details = _ClientCallDetails(self._method, timeout,
268 _unwrap_client_call_details(new_details, client_call_details))
277 continuation, client_call_details, request)
306 client_call_details = _ClientCallDetails(self._method, timeout,
[all …]
|
| 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
|