Home
last modified time | relevance | path

Searched refs:response_iterator (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_channel_close_test.py112 response_iterator = multi_callable(request_iterator)
116 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
122 response_iterator = multi_callable(request_iterator)
123 next(response_iterator)
127 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
134 response_iterator = multi_callable(request_iterator)
135 next(response_iterator)
138 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
149 response_iterator = multi_callable(request_iterator)
150 next(response_iterator)
[all …]
D_rpc_test.py252 response_iterator = multi_callable(
255 responses = tuple(response_iterator)
316 response_iterator = multi_callable(
319 responses = tuple(response_iterator)
429 response_iterator = multi_callable(
432 next(response_iterator)
438 response_iterator = multi_callable(
443 next(response_iterator)
451 response_iterator = multi_callable(
456 next(response_iterator)
[all …]
D_empty_message_test.py104 response_iterator = self._channel.unary_stream(_UNARY_STREAM)(_REQUEST)
106 list(response_iterator))
114 response_iterator = self._channel.stream_stream(_STREAM_STREAM)(iter(
117 list(response_iterator))
D_interceptor_test.py358 response_iterator = multi_callable(
364 responses = tuple(response_iterator)
368 response_iterator = multi_callable(
374 responses = tuple(response_iterator)
496 response_iterator = multi_callable(
499 tuple(response_iterator)
589 response_iterator = multi_callable(
592 tuple(response_iterator)
D_exit_scenarios.py219 response_iterator = multi_callable(REQUEST) variable
220 for response in response_iterator:
231 response_iterator = multi_callable(infinite_request_iterator()) variable
232 for response in response_iterator:
D_invocation_defects_test.py241 response_iterator = multi_callable(
246 next(response_iterator)
252 response_iterator = multi_callable(
258 next(response_iterator)
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py188 response_iterator = stub.StreamingOutputCall(request)
189 for index, response in enumerate(response_iterator):
248 response_iterator = stub.FullDuplexCall(pipe)
257 response = next(response_iterator)
286 response_iterator = stub.FullDuplexCall(pipe)
296 response = next(response_iterator)
299 response_iterator.cancel()
302 next(response_iterator)
313 response_iterator = stub.FullDuplexCall(pipe, timeout=0.001)
320 next(response_iterator)
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_client_application.py110 response_iterator = stub.UnStre(_application_common.UNARY_STREAM_REQUEST)
112 next(response_iterator)
131 response_iterator = stub.StreStre(iter(request_pipe))
133 first_responses = next(response_iterator), next(response_iterator),
135 second_responses = next(response_iterator), next(response_iterator),
138 next(response_iterator)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_service.py56 response_iterator = implementation(argument, servicer_context)
62 response = next(response_iterator)
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py76 def __init__(self, response_future, response_iterator, call): argument
78 self._iterator = response_iterator
222 response_iterator = multi_callable(
227 return _Rendezvous(None, response_iterator, response_iterator)
281 response_iterator = multi_callable(
286 return _Rendezvous(None, response_iterator, response_iterator)
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py208 response_iterator = getattr(self._dynamic_stub, _UNARY_STREAM)(
249 response_iterator = getattr(self._dynamic_stub, _STREAM_STREAM)(
253 response_iterator.protocol_context().disable_next_request_compression()
255 response = next(response_iterator)
256 response_iterator.protocol_context().disable_next_request_compression()
/external/grpc-grpc/src/python/grpcio/grpc/
D_server.py404 def _take_response_from_response_iterator(rpc_event, state, response_iterator): argument
406 return next(response_iterator), True
499 response_iterator, proceed = _call_behavior(
504 rpc_event, state, response_iterator)