| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _exit_scenarios.py | 125 def service(self, handler_call_details): argument
126 if handler_call_details.method == UNARY_UNARY:
128 elif handler_call_details.method == UNARY_STREAM:
130 elif handler_call_details.method == STREAM_UNARY:
132 elif handler_call_details.method == STREAM_STREAM:
134 elif handler_call_details.method == PARTIAL_UNARY_STREAM:
136 elif handler_call_details.method == PARTIAL_STREAM_UNARY:
138 elif handler_call_details.method == PARTIAL_STREAM_STREAM:
|
| D | _empty_message_test.py | 74 def service(self, handler_call_details): argument
75 if handler_call_details.method == _UNARY_UNARY:
77 elif handler_call_details.method == _UNARY_STREAM:
79 elif handler_call_details.method == _STREAM_UNARY:
81 elif handler_call_details.method == _STREAM_STREAM:
|
| D | _interceptor_test.py | 134 def service(self, handler_call_details): argument
135 if handler_call_details.method == _UNARY_UNARY:
139 elif handler_call_details.method == _UNARY_STREAM:
143 elif handler_call_details.method == _STREAM_UNARY:
147 elif handler_call_details.method == _STREAM_STREAM:
228 def intercept_service(self, continuation, handler_call_details): argument
230 return continuation(handler_call_details)
295 def intercept_service(self, continuation, handler_call_details): argument
296 return self._fn(continuation, handler_call_details)
301 def intercept_service(continuation, handler_call_details): argument
[all …]
|
| D | _invocation_defects_test.py | 134 def service(self, handler_call_details): argument
135 if handler_call_details.method == _UNARY_UNARY:
139 elif handler_call_details.method == _UNARY_STREAM:
143 elif handler_call_details.method == _STREAM_UNARY:
147 elif handler_call_details.method == _STREAM_STREAM:
150 elif handler_call_details.method == _DEFECTIVE_GENERIC_RPC_HANDLER:
|
| D | _metadata_test.py | 162 def service(self, handler_call_details): argument
163 if handler_call_details.method == _UNARY_UNARY:
165 elif handler_call_details.method == _UNARY_STREAM:
167 elif handler_call_details.method == _STREAM_UNARY:
169 elif handler_call_details.method == _STREAM_STREAM:
|
| D | _compression_test.py | 62 def service(self, handler_call_details): argument
63 if handler_call_details.method == _UNARY_UNARY:
65 elif handler_call_details.method == _STREAM_STREAM:
|
| D | _resource_exhausted_test.py | 121 def service(self, handler_call_details): argument
122 if handler_call_details.method == _UNARY_UNARY:
124 elif handler_call_details.method == _UNARY_STREAM:
126 elif handler_call_details.method == _STREAM_UNARY:
128 elif handler_call_details.method == _STREAM_STREAM:
|
| D | _server_test.py | 23 def service(self, handler_call_details): argument
|
| D | _rpc_test.py | 138 def service(self, handler_call_details): argument
139 if handler_call_details.method == _UNARY_UNARY:
143 elif handler_call_details.method == _UNARY_STREAM:
147 elif handler_call_details.method == _STREAM_UNARY:
151 elif handler_call_details.method == _STREAM_STREAM:
|
| D | _channel_close_test.py | 47 def service(self, handler_call_details): argument
|
| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | request_header_validator_interceptor.py | 34 def intercept_service(self, continuation, handler_call_details): argument
36 self._value) in handler_call_details.invocation_metadata:
37 return continuation(handler_call_details)
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _server_adaptations.py | 332 def service(self, handler_call_details): argument
334 handler_call_details.method)
338 handler_call_details.method),
340 handler_call_details.method))
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _utilities.py | 56 def service(self, handler_call_details): argument
57 return self._method_handlers.get(handler_call_details.method)
|
| D | _server.py | 561 def query_handlers(handler_call_details): argument
563 method_handler = generic_handler.service(handler_call_details)
568 handler_call_details = _HandlerCallDetails(
574 handler_call_details)
576 return query_handlers(handler_call_details)
|
| D | __init__.py | 1126 def service(self, handler_call_details): argument
1169 def intercept_service(self, continuation, handler_call_details): argument
|