/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/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;
|
/external/rust/crates/protobuf/src/well_known_types/ |
D | api.rs | 467 pub request_streaming: bool, field 546 self.request_streaming in get_request_streaming() 549 self.request_streaming = false; in clear_request_streaming() 554 self.request_streaming = v; in set_request_streaming() 664 self.request_streaming = tmp; in merge_from() 700 if self.request_streaming != false { in compute_size() 728 if self.request_streaming != false { in write_to_with_cached_sizes() 729 os.write_bool(3, self.request_streaming)?; in write_to_with_cached_sizes() 795 |m: &Method| { &m.request_streaming }, in descriptor_static() 796 |m: &mut Method| { &mut m.request_streaming }, in descriptor_static() [all …]
|
/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 | 1111 if (this->request_streaming() != 0) { in SerializeWithCachedSizes() 1112 …::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBool(3, this->request_streaming(), output); in SerializeWithCachedSizes() 1181 if (this->request_streaming() != 0) { in InternalSerializeWithCachedSizesToArray() 1182 …BUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(3, this->request_streaming(), target); in InternalSerializeWithCachedSizesToArray() 1269 if (this->request_streaming() != 0) { in ByteSizeLong() 1324 if (from.request_streaming() != 0) { in MergeFrom() 1325 set_request_streaming(from.request_streaming()); in MergeFrom()
|
D | api.pb.h | 452 bool request_streaming() const; 999 inline bool Method::request_streaming() const { in request_streaming() function
|
D | api.proto | 110 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:
|