| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_close_test.py | 37 def stream_stream(self, request_iterator, servicer_context): argument
38 for request in request_iterator:
111 request_iterator = _Pipe(())
112 response_iterator = multi_callable(request_iterator)
114 request_iterator.close()
121 request_iterator = _Pipe((b'abc',))
122 response_iterator = multi_callable(request_iterator)
125 request_iterator.close()
133 request_iterator = _Pipe((b'abc',))
134 response_iterator = multi_callable(request_iterator)
[all …]
|
| D | _interceptor_test.py | 85 def handle_stream_unary(self, request_iterator, servicer_context): argument
90 for request in request_iterator:
101 def handle_stream_stream(self, request_iterator, servicer_context): argument
108 for request in request_iterator:
205 request_iterator): argument
207 client_call_details, request_iterator, True, False)
212 request_iterator): argument
214 client_call_details, request_iterator, True, True)
242 request_iterator): argument
244 return continuation(client_call_details, request_iterator)
[all …]
|
| D | _rpc_test.py | 89 def handle_stream_unary(self, request_iterator, servicer_context): argument
94 for request in request_iterator:
105 def handle_stream_stream(self, request_iterator, servicer_context): argument
112 for request in request_iterator:
264 request_iterator = iter(requests)
268 request_iterator,
279 request_iterator = iter(requests)
283 request_iterator,
296 request_iterator = iter(requests)
300 request_iterator,
[all …]
|
| D | _invalid_metadata_test.py | 96 request_iterator = (
101 self._stream_unary(request_iterator, metadata=metadata)
105 request_iterator = (
111 multi_callable.with_call(request_iterator, metadata=metadata)
115 request_iterator = (
120 self._stream_unary.future(request_iterator, metadata=metadata)
124 request_iterator = (
129 self._stream_stream(request_iterator, metadata=metadata)
|
| D | _exit_scenarios.py | 73 def hang_stream_unary(request_iterator, servicer_context): argument
77 def hang_partial_stream_unary(request_iterator, servicer_context): argument
79 next(request_iterator)
83 def hang_stream_stream(request_iterator, servicer_context): argument
87 def hang_partial_stream_stream(request_iterator, servicer_context): argument
89 yield next(request_iterator)
|
| D | _empty_message_test.py | 40 def handle_stream_unary(request_iterator, servicer_context): argument
41 for request in request_iterator:
46 def handle_stream_stream(request_iterator, servicer_context): argument
47 for request in request_iterator:
|
| D | _metadata_test.py | 116 def handle_stream_unary(test, request_iterator, servicer_context): argument
121 for request in request_iterator:
126 def handle_stream_stream(test, request_iterator, servicer_context): argument
132 for request in request_iterator:
|
| D | _invocation_defects_test.py | 82 def handle_stream_unary(self, request_iterator, servicer_context): argument
87 for request in request_iterator:
98 def handle_stream_stream(self, request_iterator, servicer_context): argument
105 for request in request_iterator:
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _multi_callable.py | 67 request_iterator, argument
74 _invocation.consume_requests(request_iterator, rpc_handler)
78 request_iterator, argument
85 _invocation.consume_requests(request_iterator, rpc_handler)
89 request_iterator, argument
96 _invocation.consume_requests(request_iterator, rpc_handler)
107 request_iterator, argument
114 _invocation.consume_requests(request_iterator, rpc_handler)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 290 request_iterator, argument
295 request_iterator,
302 request_iterator, argument
309 def continuation(new_details, request_iterator): argument
314 request_iterator,
325 continuation, client_call_details, request_iterator)
329 request_iterator, argument
334 request_iterator,
340 request_iterator, argument
347 def continuation(new_details, request_iterator): argument
[all …]
|
| D | __init__.py | 444 request_iterator): argument
482 request_iterator): argument
706 request_iterator, argument
733 request_iterator, argument
760 request_iterator, argument
789 request_iterator, argument
|
| D | _channel.py | 179 def _consume_request_iterator(request_iterator, state, call, request_serializer, argument
192 request = next(request_iterator)
600 def _blocking(self, request_iterator, timeout, metadata, credentials): argument
607 _consume_request_iterator(request_iterator, state, call,
619 request_iterator, argument
623 state, call, = self._blocking(request_iterator, timeout, metadata,
628 request_iterator, argument
632 state, call, = self._blocking(request_iterator, timeout, metadata,
637 request_iterator, argument
648 _consume_request_iterator(request_iterator, state, call,
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_server.py | 26 def StreamingCall(self, request_iterator, context): argument
27 for request in request_iterator:
42 def StreamingCall(self, request_iterator, context): argument
43 for request in request_iterator:
|
| D | worker_server.py | 41 def RunServer(self, request_iterator, context): argument
42 config = next(request_iterator).setup
49 for request in request_iterator:
104 def RunClient(self, request_iterator, context): argument
105 config = next(request_iterator).setup
122 for request in request_iterator:
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 70 def stream_unary(self, request_iterator, context): argument
71 for request in request_iterator:
81 def stream_stream(self, request_iterator, context): argument
82 for request in request_iterator:
225 request_iterator = _BlockingIterator(iter((_REQUEST,)))
227 request_iterator,
231 request_iterator.allow()
233 request_iterator.allow()
248 request_iterator = _BlockingIterator(iter((_REQUEST,)))
250 request_iterator,
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 232 request_iterator, request_serializer, argument
242 request_iterator,
249 request_iterator,
258 metadata, metadata_transformer, request_iterator, argument
266 request_iterator,
274 metadata_transformer, request_iterator, request_serializer, argument
282 request_iterator,
366 request_iterator, argument
374 request_iterator, self._request_serializer,
378 request_iterator, argument
[all …]
|
| D | _server_adaptations.py | 97 def adaptation(request_iterator, servicer_context): argument
98 return stream_request_inline(request_iterator,
158 def _run_request_pipe_thread(request_iterator, request_consumer, argument
163 for request in request_iterator:
209 def adaptation(request_iterator, servicer_context): argument
216 _run_request_pipe_thread(request_iterator, request_consumer,
225 def adaptation(request_iterator, servicer_context): argument
231 _run_request_pipe_thread(request_iterator, request_consumer,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
| D | _server_application.py | 43 def StreUn(self, request_iterator, context): argument
48 for request in request_iterator:
58 def StreStre(self, request_iterator, context): argument
59 for request in request_iterator:
|
| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | generic_client_interceptor.py | 40 request_iterator): argument
42 client_call_details, request_iterator, True, False)
47 request_iterator): argument
49 client_call_details, request_iterator, True, True)
|
| D | header_manipulator_client_interceptor.py | 32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
44 return client_call_details, request_iterator, None
|
| /external/grpc-grpc/examples/python/route_guide/ |
| D | route_guide_server.py | 84 def RecordRoute(self, request_iterator, context): argument
91 for point in request_iterator:
106 def RouteChat(self, request_iterator, context): argument
108 for new_note in request_iterator:
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | face.py | 487 request_iterator, argument
515 request_iterator, argument
568 request_iterator, argument
786 request_iterator, argument
821 request_iterator, argument
848 request_iterator, argument
|
| /external/grpc-grpc/examples/python/multiplex/ |
| D | multiplex_server.py | 92 def RecordRoute(self, request_iterator, context): argument
99 for point in request_iterator:
114 def RouteChat(self, request_iterator, context): argument
116 for new_note in request_iterator:
|
| /external/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
|
| /external/grpc-grpc/examples/python/interceptors/default_value/ |
| D | default_value_client_interceptor.py | 66 request_iterator): argument
68 request_iterator)
|