Home
last modified time | relevance | path

Searched refs:response_future (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_rpc_test.py235 response_future = multi_callable.future(
238 response = response_future.result()
240 self.assertIsInstance(response_future, grpc.Future)
241 self.assertIsInstance(response_future, grpc.Call)
243 self.assertIsNone(response_future.exception())
244 self.assertIsNone(response_future.traceback())
299 response_future = multi_callable.future(
302 response = response_future.result()
305 self.assertIsNone(response_future.exception())
306 self.assertIsNone(response_future.traceback())
[all …]
D_interceptor_test.py475 response_future = multi_callable.future(
478 response_future.result()
566 response_future = multi_callable.future(
569 response_future.result()
D_invocation_defects_test.py231 response_future = multi_callable.future(
236 response = response_future.result()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py265 response_future = service.stub.UnaryCall.future(request)
266 response = response_future.result()
276 response_future = service.stub.UnaryCall.future(
279 response_future.result()
282 self.assertIs(response_future.code(), grpc.StatusCode.DEADLINE_EXCEEDED)
289 response_future = service.stub.UnaryCall.future(request)
290 response_future.cancel()
291 self.assertTrue(response_future.cancelled())
292 self.assertIs(response_future.code(), grpc.StatusCode.CANCELLED)
299 response_future = service.stub.UnaryCall.future(request)
[all …]
Dbeta_python_plugin_test.py386 response_future = stub.UnaryCall.future(
388 response = response_future.result()
399 response_future = stub.UnaryCall.future(
402 response_future.result()
411 response_future = stub.UnaryCall.future(request, 1)
412 response_future.cancel()
413 self.assertTrue(response_future.cancelled())
422 response_future = stub.UnaryCall.future(
424 self.assertIsNotNone(response_future.exception())
498 response_future = stub.StreamingInputCall.future(
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py137 response_future = stub.UnaryCall.future(
139 response = response_future.result()
264 response_future = stub.StreamingInputCall.future(pipe)
265 response_future.cancel()
266 if not response_future.cancelled():
268 if response_future.code() is not grpc.StatusCode.CANCELLED:
350 response_future = stub.UnaryCall.future(request)
351 _validate_status_code_and_details(response_future, status, details)
367 response_future = (test_service_stub.UnimplementedCall.future(
369 _expect_status_code(response_future, grpc.StatusCode.UNIMPLEMENTED)
[all …]
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py76 def __init__(self, response_future, response_iterator, call): argument
77 self._future = response_future
206 response_future = multi_callable.future(
211 return _Rendezvous(response_future, None, response_future)
265 response_future = multi_callable.future(
270 return _Rendezvous(response_future, None, response_future)
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py226 response_future = getattr(self._dynamic_stub, _STREAM_UNARY).future(
230 response_future.protocol_context().disable_next_request_compression()
232 response_future.protocol_context().disable_next_request_compression()
236 self.assertEqual(_RESPONSE, response_future.result())
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_client.py125 response_future = self._stub.UnaryCall.future(self._request, _TIMEOUT)
126 response_future.add_done_callback(
/external/grpc-grpc/src/python/grpcio_tests/tests/fork/
Dmethods.py60 response_future = stub.UnaryCall.future(request)
61 response = response_future.result()