/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/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 | 1209 if (this->response_streaming() != 0) { in SerializeWithCachedSizes() 1210 ::google::protobuf::internal::WireFormatLite::WriteBool(5, this->response_streaming(), output); in SerializeWithCachedSizes() 1270 if (this->response_streaming() != 0) { in SerializeWithCachedSizesToArray() 1271 …oogle::protobuf::internal::WireFormatLite::WriteBoolToArray(5, this->response_streaming(), target); in SerializeWithCachedSizesToArray() 1322 if (this->response_streaming() != 0) { in ByteSize() 1380 if (from.response_streaming() != 0) { in MergeFrom() 1381 set_response_streaming(from.response_streaming()); in MergeFrom() 1584 bool Method::response_streaming() const { in response_streaming() function in google::protobuf::Method
|
D | api.pb.h | 297 bool response_streaming() const; 825 inline bool Method::response_streaming() const { in response_streaming() function
|
D | api.proto | 109 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:
|