| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | client_stream_unary_interceptor_test.py | 40 request_iterator): argument
51 request_iterator): argument
84 async def request_iterator(): function
162 async def request_iterator(): function
192 async def request_iterator(): function
222 async def request_iterator(): function
262 async def request_iterator(): function
318 request_iterator): argument
361 request_iterator): argument
435 request_iterator): argument
[all …]
|
| D | client_stream_stream_interceptor_test.py | 33 request_iterator): argument
44 request_iterator): argument
83 async def request_iterator(): function
|
| D | server_test.py | 126 async def _stream_unary_async_gen(self, request_iterator, unused_context): argument
139 async def _stream_unary_evilly_mixed(self, request_iterator, context): argument
148 async def _stream_stream_async_gen(self, request_iterator, unused_context): argument
164 async def _stream_stream_evilly_mixed(self, request_iterator, context): argument
176 async def _error_in_stream_stream(self, request_iterator, unused_context): argument
186 async def _error_without_raise_in_stream_stream(self, request_iterator, argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/interop/ |
| D | service.py | 72 def StreamingInputCall(self, request_iterator, context): argument
80 def FullDuplexCall(self, request_iterator, context): argument
95 def HalfDuplexCall(self, request_iterator, context): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/benchmark/ |
| D | worker_servicer.py | 184 async def _run_single_server(self, config, request_iterator, context): argument
200 async def RunServer(self, request_iterator, context): argument
266 async def _run_single_client(self, config, request_iterator, context): argument
295 async def RunClient(self, request_iterator, context): argument
|
| D | benchmark_servicer.py | 37 async def StreamingCall(self, request_iterator, unused_context): argument
53 async def StreamingCall(self, request_iterator, unused_context): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/testing/ |
| D | _server_application.py | 62 def StreUn(self, request_iterator, context): argument
77 def StreStre(self, request_iterator, context): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_server.py | 26 def StreamingCall(self, request_iterator, context): argument
42 def StreamingCall(self, request_iterator, context): argument
|
| D | worker_server.py | 42 def RunServer(self, request_iterator, context): argument
110 def RunClient(self, request_iterator, context): argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _interceptor_test.py | 97 def handle_stream_unary(self, request_iterator, servicer_context): argument
115 def handle_stream_stream(self, request_iterator, servicer_context): argument
220 request_iterator): argument
227 request_iterator): argument
267 request_iterator): argument
279 request_iterator): argument
293 def intercept_call(client_call_details, request_iterator, request_streaming, argument
305 def intercept_call(client_call_details, request_iterator, argument
374 def triple(request_iterator): argument
|
| D | _exit_scenarios.py | 74 def hang_stream_unary(request_iterator, servicer_context): argument
78 def hang_partial_stream_unary(request_iterator, servicer_context): argument
84 def hang_stream_stream(request_iterator, servicer_context): argument
88 def hang_partial_stream_stream(request_iterator, servicer_context): argument
|
| D | _empty_message_test.py | 41 def handle_stream_unary(request_iterator, servicer_context): argument
47 def handle_stream_stream(request_iterator, servicer_context): argument
|
| /third_party/grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _multi_callable.py | 67 request_iterator, argument
78 request_iterator, argument
89 request_iterator, argument
107 request_iterator, argument
|
| /third_party/grpc/examples/python/data_transmission/ |
| D | server.py | 44 def ClientStreamingMethod(self, request_iterator, context): argument
75 def BidirectionalStreamingMethod(self, request_iterator, context): argument
|
| D | demo_pb2_grpc.py | 53 def ClientStreamingMethod(self, request_iterator, context): argument
71 def BidirectionalStreamingMethod(self, request_iterator, context): argument
|
| /third_party/grpc/examples/python/multiplex/ |
| D | route_guide_pb2_grpc.py | 67 def RecordRoute(self, request_iterator, context): argument
77 def RouteChat(self, request_iterator, context): argument
|
| D | multiplex_server.py | 91 def RecordRoute(self, request_iterator, context): argument
112 def RouteChat(self, request_iterator, context): argument
|
| /third_party/grpc/examples/python/route_guide/ |
| D | route_guide_pb2_grpc.py | 67 def RecordRoute(self, request_iterator, context): argument
77 def RouteChat(self, request_iterator, context): argument
|
| D | route_guide_server.py | 83 def RecordRoute(self, request_iterator, context): argument
104 def RouteChat(self, request_iterator, context): argument
|
| /third_party/grpc/examples/python/interceptors/headers/ |
| D | generic_client_interceptor.py | 41 request_iterator): argument
48 request_iterator): argument
|
| D | header_manipulator_client_interceptor.py | 32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| D | _python_plugin_test.py | 153 def StreamingInputCall(self, request_iterator, context): argument
157 def FullDuplexCall(self, request_iterator, context): argument
160 def HalfDuplexCall(self, request_iterator, context): argument
522 def StreamingInputCall(self, request_iterator, context): argument
526 def FullDuplexCall(self, request_iterator, context): argument
530 def HalfDuplexCall(self, request_iterator, context): argument
|
| /third_party/flatbuffers/tests/MyGame/Example/ |
| D | monster_test_grpc_fb.py | 47 def GetMaxHitPoint(self, request_iterator, context): argument
136 def GetMaxHitPoint(self, request_iterator, context): argument
185 def GetMaxHitPoint(self, request_iterator, context): argument
202 …def GetMaxHitPoint(self, request_iterator, timeout, metadata=None, with_call=False, protocol_optio… argument
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 349 request_iterator, argument
364 request_iterator, argument
374 def continuation(new_details, request_iterator): argument
399 request_iterator, argument
413 request_iterator, argument
423 def continuation(new_details, request_iterator): argument
451 request_iterator, argument
461 def continuation(new_details, request_iterator): argument
|
| /third_party/grpc/src/python/grpcio/grpc/beta/ |
| D | _server_adaptations.py | 97 def adaptation(request_iterator, servicer_context): argument
158 def _run_request_pipe_thread(request_iterator, request_consumer, argument
209 def adaptation(request_iterator, servicer_context): argument
225 def adaptation(request_iterator, servicer_context): argument
|