| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _empty_message_test.py | 54 def __init__(self, request_streaming, response_streaming): argument
55 self.request_streaming = request_streaming
63 if self.request_streaming and self.response_streaming:
65 elif self.request_streaming:
|
| D | _error_message_encoding_test.py | 38 def __init__(self, request_streaming=None, response_streaming=None): argument
39 self.request_streaming = request_streaming
|
| D | _metadata_test.py | 139 def __init__(self, test, request_streaming, response_streaming): argument
140 self.request_streaming = request_streaming
148 if self.request_streaming and self.response_streaming:
150 elif self.request_streaming:
|
| D | _exit_scenarios.py | 96 def __init__(self, request_streaming, response_streaming, partial_hang): argument
97 self.request_streaming = request_streaming
105 if self.request_streaming and self.response_streaming:
110 elif self.request_streaming:
|
| D | _compression_test.py | 134 def __init__(self, request_streaming, response_streaming, argument
136 self.request_streaming = request_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
63 self.request_streaming = request_streaming
71 if self.request_streaming and self.response_streaming:
74 elif self.request_streaming:
|
| D | _resource_exhausted_test.py | 97 def __init__(self, trigger, request_streaming, response_streaming): argument
98 self.request_streaming = request_streaming
106 if self.request_streaming and self.response_streaming:
109 elif self.request_streaming:
|
| D | _invocation_defects_test.py | 95 def __init__(self, request_streaming, response_streaming, argument
98 self.request_streaming = request_streaming
|
| D | _channel_close_test.py | 37 request_streaming = True variable in _StreamingMethodHandler
49 request_streaming = False variable in _UnaryMethodHandler
|
| D | _interceptor_test.py | 132 def __init__(self, request_streaming, response_streaming, argument
135 self.request_streaming = request_streaming
293 def intercept_call(client_call_details, request_iterator, request_streaming, argument
295 if request_streaming:
|
| D | _rpc_test_helpers.py | 156 def __init__(self, request_streaming, response_streaming, argument
159 self.request_streaming = request_streaming
|
| D | _rpc_test.py | 157 def __init__(self, request_streaming, response_streaming, argument
160 self.request_streaming = request_streaming
|
| /third_party/protobuf/php/src/Google/Protobuf/ |
| D | Method.php | 35 private $request_streaming = false; variable in Google\\Protobuf\\Method
148 return $this->request_streaming;
161 $this->request_streaming = $var;
|
| /third_party/grpc/examples/python/interceptors/headers/ |
| D | header_manipulator_client_interceptor.py | 32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
|
| /third_party/grpc/src/python/grpcio/grpc/experimental/ |
| D | __init__.py | 100 if not handler.request_streaming:
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_async.cc | 130 auto request_streaming = std::bind( in AsyncQpsServerTest() local
135 request_streaming, process_rpc_bound)); in AsyncQpsServerTest()
|
| /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 | 99 if handler and (handler.request_streaming or # pytype: disable=attribute-error
|
| /third_party/protobuf/src/google/protobuf/ |
| D | api.pb.cc | 817 if (this->request_streaming() != 0) { in _InternalSerialize()
898 if (this->request_streaming() != 0) { in ByteSizeLong()
954 if (from.request_streaming() != 0) { in MergeFrom()
|
| D | api.proto | 110 bool request_streaming = 3; field
|
| D | api.pb.h | 521 bool request_streaming() const;
1206 inline bool Method::request_streaming() const { in request_streaming() function
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _server.py | 713 if method_handler.request_streaming:
|