| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _compression_test.py | 45 def __init__(self, request_streaming, response_streaming): argument
46 self.request_streaming = request_streaming
54 if self.request_streaming and self.response_streaming:
56 elif not self.request_streaming and not self.response_streaming:
|
| D | _empty_message_test.py | 53 def __init__(self, request_streaming, response_streaming): argument
54 self.request_streaming = request_streaming
62 if self.request_streaming and self.response_streaming:
64 elif self.request_streaming:
|
| D | _metadata_test.py | 138 def __init__(self, test, request_streaming, response_streaming): argument
139 self.request_streaming = request_streaming
147 if self.request_streaming and self.response_streaming:
149 elif self.request_streaming:
|
| D | _exit_scenarios.py | 95 def __init__(self, request_streaming, response_streaming, partial_hang): argument
96 self.request_streaming = request_streaming
104 if self.request_streaming and self.response_streaming:
109 elif self.request_streaming:
|
| D | _resource_exhausted_test.py | 96 def __init__(self, trigger, request_streaming, response_streaming): argument
97 self.request_streaming = request_streaming
105 if self.request_streaming and self.response_streaming:
108 elif self.request_streaming:
|
| D | _invocation_defects_test.py | 116 def __init__(self, request_streaming, response_streaming, argument
119 self.request_streaming = request_streaming
|
| D | _interceptor_test.py | 116 def __init__(self, request_streaming, response_streaming, argument
119 self.request_streaming = request_streaming
261 def intercept_call(client_call_details, request_iterator, request_streaming, argument
263 if request_streaming:
|
| D | _channel_close_test.py | 32 request_streaming = True variable in _MethodHandler
|
| D | _rpc_test.py | 120 def __init__(self, request_streaming, response_streaming, argument
123 self.request_streaming = request_streaming
|
| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | header_manipulator_client_interceptor.py | 32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
|
| /external/protobuf/src/google/protobuf/ |
| D | api.pb.cc | 1194 if (this->request_streaming() != 0) { in SerializeWithCachedSizes()
1195 ::google::protobuf::internal::WireFormatLite::WriteBool(3, this->request_streaming(), output); in SerializeWithCachedSizes()
1254 if (this->request_streaming() != 0) { in SerializeWithCachedSizesToArray()
1255 …google::protobuf::internal::WireFormatLite::WriteBoolToArray(3, this->request_streaming(), target); in SerializeWithCachedSizesToArray()
1310 if (this->request_streaming() != 0) { in ByteSize()
1373 if (from.request_streaming() != 0) { in MergeFrom()
1374 set_request_streaming(from.request_streaming()); in MergeFrom()
1526 bool Method::request_streaming() const { in request_streaming() function in google::protobuf::Method
|
| D | api.pb.h | 280 bool request_streaming() const;
767 inline bool Method::request_streaming() const { in request_streaming() function
|
| D | api.proto | 103 bool request_streaming = 3; field
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 126 auto request_streaming = std::bind( in AsyncQpsServerTest() local
131 request_streaming, process_rpc_bound)); in AsyncQpsServerTest()
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 599 if method_handler.request_streaming:
|