| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_close_test.py | 42 def stream_stream(self, request_iterator, servicer_context): argument
43 for request in request_iterator:
131 request_iterator = _Pipe(())
132 response_iterator = multi_callable(request_iterator)
134 request_iterator.close()
141 request_iterator = _Pipe((b'abc',))
142 response_iterator = multi_callable(request_iterator)
145 request_iterator.close()
153 request_iterator = _Pipe((b'abc',))
154 response_iterator = multi_callable(request_iterator)
[all …]
|
| D | _interceptor_test.py | 97 def handle_stream_unary(self, request_iterator, servicer_context): argument
102 for request in request_iterator:
115 def handle_stream_stream(self, request_iterator, servicer_context): argument
122 for request in request_iterator:
220 request_iterator): argument
222 client_call_details, request_iterator, True, False)
227 request_iterator): argument
229 client_call_details, request_iterator, True, True)
267 request_iterator): argument
269 result = continuation(client_call_details, request_iterator)
[all …]
|
| D | _rpc_test.py | 112 def handle_stream_unary(self, request_iterator, servicer_context): argument
117 for request in request_iterator:
128 def handle_stream_stream(self, request_iterator, servicer_context): argument
135 for request in request_iterator:
140 def handle_stream_stream_non_blocking(self, request_iterator, argument
148 for request in request_iterator:
329 request_iterator = iter(requests)
333 request_iterator,
344 request_iterator = iter(requests)
348 request_iterator,
[all …]
|
| D | _rpc_test_helpers.py | 111 def handle_stream_unary(self, request_iterator, servicer_context): argument
116 for request in request_iterator:
127 def handle_stream_stream(self, request_iterator, servicer_context): argument
134 for request in request_iterator:
139 def handle_stream_stream_non_blocking(self, request_iterator, argument
147 for request in request_iterator:
273 request_iterator = iter(requests)
276 request_iterator,
285 request_iterator = iter(requests)
288 request_iterator,
[all …]
|
| D | _invalid_metadata_test.py | 98 request_iterator = (
103 self._stream_unary(request_iterator, metadata=metadata)
107 request_iterator = (
113 multi_callable.with_call(request_iterator, metadata=metadata)
117 request_iterator = (
122 self._stream_unary.future(request_iterator, metadata=metadata)
126 request_iterator = (
131 self._stream_stream(request_iterator, metadata=metadata)
|
| D | _rpc_part_1_test.py | 38 request_iterator = iter(requests)
44 request_iterator,
60 request_iterator = iter(requests)
66 request_iterator,
151 request_iterator = iter(requests)
157 request_iterator,
167 request_iterator = iter(requests)
173 request_iterator,
214 request_iterator = iter(requests)
218 request_iterator,
|
| D | _rpc_part_2_test.py | 113 request_iterator = iter(requests)
117 request_iterator,
128 request_iterator = iter(requests)
132 request_iterator,
145 request_iterator = iter(requests)
149 request_iterator,
163 request_iterator = iter(requests)
167 request_iterator,
204 request_iterator = iter(requests)
207 request_iterator,
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | client_stream_unary_interceptor_test.py | 40 request_iterator): argument
41 return await continuation(client_call_details, request_iterator)
51 request_iterator): argument
52 self.request_iterator = CountingRequestIterator(request_iterator)
53 call = await continuation(client_call_details, self.request_iterator)
58 self.request_iterator.request_cnt)
84 async def request_iterator(): function
88 call = stub.StreamingInputCall(request_iterator())
162 async def request_iterator(): function
166 call = stub.StreamingInputCall(request_iterator())
[all …]
|
| D | compatibility_test.py | 316 def echo_stream_unary(request_iterator: Iterable[bytes],
318 self.assertEqual(len(list(request_iterator)), _NUM_STREAM_RESPONSES)
322 request_iterator = iter([_REQUEST] * _NUM_STREAM_RESPONSES)
324 request_iterator)
330 def echo_stream_unary(request_iterator: Iterable[bytes],
332 self.assertEqual(len(list(request_iterator)), _NUM_STREAM_RESPONSES)
336 request_iterator = iter([_REQUEST] * _NUM_STREAM_RESPONSES)
339 request_iterator)
346 def echo_stream_stream(request_iterator: Iterable[bytes],
348 for request in request_iterator:
[all …]
|
| D | client_stream_stream_interceptor_test.py | 33 request_iterator): argument
34 return await continuation(client_call_details, request_iterator)
44 request_iterator): argument
45 self.request_iterator = CountingRequestIterator(request_iterator)
46 call = await continuation(client_call_details, self.request_iterator)
52 self.request_iterator.request_cnt)
83 async def request_iterator(): function
87 call = stub.FullDuplexCall(request_iterator())
|
| /third_party/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)
|
| /third_party/grpc/src/python/grpcio_tests/tests/interop/ |
| D | service.py | 72 def StreamingInputCall(self, request_iterator, context): argument
74 for request in request_iterator:
80 def FullDuplexCall(self, request_iterator, context): argument
82 for request in request_iterator:
95 def HalfDuplexCall(self, request_iterator, context): argument
96 return self.FullDuplexCall(request_iterator, context)
|
| /third_party/grpc/src/python/grpcio/grpc/experimental/aio/ |
| D | _interceptor.py | 174 request_iterator: RequestIterableType,
215 request_iterator: RequestIterableType,
472 self, request_iterator: Optional[RequestIterableType]
475 if request_iterator is None:
481 request_iterator = self._write_to_iterator_async_gen
485 return request_iterator
715 request_iterator: Optional[RequestIterableType],
724 request_iterator = self._init_stream_request_mixin(request_iterator)
727 wait_for_ready, request_iterator, request_serializer,
738 request_iterator: RequestIterableType,
[all …]
|
| /third_party/grpc/src/python/grpcio/grpc/aio/ |
| D | _interceptor.py | 174 request_iterator: RequestIterableType,
215 request_iterator: RequestIterableType,
471 self, request_iterator: Optional[RequestIterableType]
474 if request_iterator is None:
480 request_iterator = self._write_to_iterator_async_gen
484 return request_iterator
714 request_iterator: Optional[RequestIterableType],
723 request_iterator = self._init_stream_request_mixin(request_iterator)
726 wait_for_ready, request_iterator, request_serializer,
737 request_iterator: RequestIterableType,
[all …]
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 349 request_iterator, argument
355 response, ignored_call = self._with_call(request_iterator,
364 request_iterator, argument
374 def continuation(new_details, request_iterator): argument
381 request_iterator,
395 request_iterator)
399 request_iterator, argument
405 return self._with_call(request_iterator,
413 request_iterator, argument
423 def continuation(new_details, request_iterator): argument
[all …]
|
| /third_party/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:
|
| /third_party/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:
228 request_iterator = _BlockingIterator(iter((_REQUEST,)))
230 request_iterator,
234 request_iterator.allow()
236 request_iterator.allow()
251 request_iterator = _BlockingIterator(iter((_REQUEST,)))
253 request_iterator,
[all …]
|
| /third_party/grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 231 request_iterator, request_serializer, argument
241 request_iterator,
247 return multi_callable(request_iterator,
256 metadata, metadata_transformer, request_iterator, argument
264 request_iterator,
272 metadata_transformer, request_iterator, request_serializer, argument
280 request_iterator,
367 request_iterator, argument
375 request_iterator,
380 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,
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/benchmark/ |
| D | benchmark_servicer.py | 37 async def StreamingCall(self, request_iterator, unused_context): argument
38 async for request in request_iterator:
53 async def StreamingCall(self, request_iterator, unused_context): argument
54 async for _ in request_iterator:
|
| D | worker_servicer.py | 184 async def _run_single_server(self, config, request_iterator, context): argument
192 async for request in request_iterator:
200 async def RunServer(self, request_iterator, context): argument
215 await self._run_single_server(config, request_iterator, context)
240 async for request in request_iterator:
266 async def _run_single_client(self, config, request_iterator, context): argument
283 async for request in request_iterator:
295 async def RunClient(self, request_iterator, context): argument
308 await self._run_single_client(config, request_iterator, context)
330 async for request in request_iterator:
|
| /third_party/grpc/examples/python/data_transmission/ |
| D | server.py | 44 def ClientStreamingMethod(self, request_iterator, context): argument
46 for request in request_iterator:
75 def BidirectionalStreamingMethod(self, request_iterator, context): argument
81 for request in request_iterator:
|
| /third_party/grpc/examples/python/interceptors/headers/ |
| D | generic_client_interceptor.py | 41 request_iterator): argument
43 client_call_details, request_iterator, True, False)
48 request_iterator): argument
50 client_call_details, request_iterator, True, True)
|
| /third_party/grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| D | _python_plugin_test.py | 153 def StreamingInputCall(self, request_iterator, context): argument
154 return servicer_methods.StreamingInputCall(request_iterator,
157 def FullDuplexCall(self, request_iterator, context): argument
158 return servicer_methods.FullDuplexCall(request_iterator, context)
160 def HalfDuplexCall(self, request_iterator, context): argument
161 return servicer_methods.HalfDuplexCall(request_iterator, context)
418 request_iterator = _full_duplex_request_iterator()
422 request_iterator, timeout=test_constants.SHORT_TIMEOUT)
431 request_iterator = _full_duplex_request_iterator()
432 responses = service.stub.FullDuplexCall(request_iterator)
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/testing/ |
| D | _server_application.py | 62 def StreUn(self, request_iterator, context): argument
67 for request in request_iterator:
77 def StreStre(self, request_iterator, context): argument
80 for request in request_iterator:
|