| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _compression_test.py | 45 def __init__(self, request_streaming, response_streaming): argument
47 self.response_streaming = response_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
55 self.response_streaming = response_streaming
62 if self.request_streaming and self.response_streaming:
66 elif self.response_streaming:
|
| D | _metadata_test.py | 138 def __init__(self, test, request_streaming, response_streaming): argument
140 self.response_streaming = response_streaming
147 if self.request_streaming and self.response_streaming:
151 elif self.response_streaming:
|
| D | _exit_scenarios.py | 95 def __init__(self, request_streaming, response_streaming, partial_hang): argument
97 self.response_streaming = response_streaming
104 if self.request_streaming and self.response_streaming:
114 elif self.response_streaming:
|
| D | _resource_exhausted_test.py | 96 def __init__(self, trigger, request_streaming, response_streaming): argument
98 self.response_streaming = response_streaming
105 if self.request_streaming and self.response_streaming:
110 elif self.response_streaming:
|
| D | _invocation_defects_test.py | 116 def __init__(self, request_streaming, response_streaming, argument
120 self.response_streaming = response_streaming
|
| D | _interceptor_test.py | 116 def __init__(self, request_streaming, response_streaming, argument
120 self.response_streaming = response_streaming
|
| D | _channel_close_test.py | 33 response_streaming = True variable in _MethodHandler
|
| D | _rpc_test.py | 120 def __init__(self, request_streaming, response_streaming, argument
124 self.response_streaming = response_streaming
|
| /external/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;
|
| /external/rust/crates/protobuf/src/well_known_types/ |
| D | api.rs | 469 pub response_streaming: bool, field
587 self.response_streaming in get_response_streaming()
590 self.response_streaming = false; in clear_response_streaming()
595 self.response_streaming = v; in set_response_streaming()
674 self.response_streaming = tmp; in merge_from()
706 if self.response_streaming != false { in compute_size()
734 if self.response_streaming != false { in write_to_with_cached_sizes()
735 os.write_bool(5, self.response_streaming)?; in write_to_with_cached_sizes()
805 |m: &Method| { &m.response_streaming }, in descriptor_static()
806 |m: &mut Method| { &mut m.response_streaming }, in descriptor_static()
[all …]
|
| /external/grpc-grpc/examples/python/interceptors/headers/ |
| D | header_manipulator_client_interceptor.py | 33 response_streaming): argument
|
| /external/protobuf/src/google/protobuf/ |
| D | api.pb.cc | 1126 if (this->response_streaming() != 0) { in SerializeWithCachedSizes()
1127 …::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBool(5, this->response_streaming(), output… in SerializeWithCachedSizes()
1197 if (this->response_streaming() != 0) { in InternalSerializeWithCachedSizesToArray()
1198 …UF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(5, this->response_streaming(), target); in InternalSerializeWithCachedSizesToArray()
1274 if (this->response_streaming() != 0) { in ByteSizeLong()
1327 if (from.response_streaming() != 0) { in MergeFrom()
1328 set_response_streaming(from.response_streaming()); in MergeFrom()
|
| D | api.pb.h | 457 bool response_streaming() const;
1064 inline bool Method::response_streaming() const { in response_streaming() function
|
| D | api.proto | 116 bool response_streaming = 5; field
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 600 if method_handler.response_streaming:
607 if method_handler.response_streaming:
|