/third_party/grpc/src/python/grpcio_tests/tests/unit/ |
D | _empty_message_test.py | 54 def __init__(self, request_streaming, response_streaming): argument 56 self.response_streaming = response_streaming 63 if self.request_streaming and self.response_streaming: 67 elif self.response_streaming:
|
D | _error_message_encoding_test.py | 38 def __init__(self, request_streaming=None, response_streaming=None): argument 40 self.response_streaming = response_streaming
|
D | _metadata_test.py | 139 def __init__(self, test, request_streaming, response_streaming): argument 141 self.response_streaming = response_streaming 148 if self.request_streaming and self.response_streaming: 152 elif self.response_streaming:
|
D | _exit_scenarios.py | 96 def __init__(self, request_streaming, response_streaming, partial_hang): argument 98 self.response_streaming = response_streaming 105 if self.request_streaming and self.response_streaming: 115 elif self.response_streaming:
|
D | _compression_test.py | 134 def __init__(self, request_streaming, response_streaming, argument 137 self.response_streaming = response_streaming 145 if self.request_streaming and self.response_streaming: 148 elif not self.request_streaming and not self.response_streaming: 150 elif not self.request_streaming and self.response_streaming:
|
D | _metadata_flags_test.py | 62 def __init__(self, test, request_streaming, response_streaming): argument 64 self.response_streaming = response_streaming 71 if self.request_streaming and self.response_streaming: 77 elif self.response_streaming:
|
D | _resource_exhausted_test.py | 97 def __init__(self, trigger, request_streaming, response_streaming): argument 99 self.response_streaming = response_streaming 106 if self.request_streaming and self.response_streaming: 111 elif self.response_streaming:
|
D | _invocation_defects_test.py | 95 def __init__(self, request_streaming, response_streaming, argument 99 self.response_streaming = response_streaming
|
D | _channel_close_test.py | 38 response_streaming = True variable in _StreamingMethodHandler 50 response_streaming = False variable in _UnaryMethodHandler
|
D | _rpc_test_helpers.py | 156 def __init__(self, request_streaming, response_streaming, argument 160 self.response_streaming = response_streaming
|
D | _interceptor_test.py | 132 def __init__(self, request_streaming, response_streaming, argument 136 self.response_streaming = response_streaming
|
D | _rpc_test.py | 157 def __init__(self, request_streaming, response_streaming, argument 161 self.response_streaming = response_streaming
|
/third_party/protobuf/php/src/Google/Protobuf/ |
D | Method.php | 47 private $response_streaming = false; variable in Google\\Protobuf\\Method 200 return $this->response_streaming; 213 $this->response_streaming = $var;
|
/third_party/grpc/src/python/grpcio/grpc/experimental/ |
D | __init__.py | 101 if not handler.response_streaming: 108 if not handler.response_streaming:
|
/third_party/grpc/examples/python/interceptors/headers/ |
D | header_manipulator_client_interceptor.py | 33 response_streaming): argument
|
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
D | server.pyx.pxi | 744 if not method_handler.request_streaming and not method_handler.response_streaming: 751 if not method_handler.request_streaming and method_handler.response_streaming: 758 if method_handler.request_streaming and not method_handler.response_streaming: 765 if method_handler.request_streaming and method_handler.response_streaming:
|
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
D | server_interceptor_test.py | 100 handler.response_streaming): # pytype: disable=attribute-error
|
/third_party/protobuf/src/google/protobuf/ |
D | api.pb.cc | 833 if (this->response_streaming() != 0) { in _InternalSerialize() 903 if (this->response_streaming() != 0) { in ByteSizeLong() 957 if (from.response_streaming() != 0) { in MergeFrom()
|
D | api.proto | 116 bool response_streaming = 5; field
|
D | api.pb.h | 530 bool response_streaming() const; 1288 inline bool Method::response_streaming() const { in response_streaming() function
|
/third_party/grpc/src/python/grpcio/grpc/ |
D | _server.py | 714 if method_handler.response_streaming: 721 if method_handler.response_streaming:
|