Home
last modified time | relevance | path

Searched refs:request_streaming (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_compression_test.py45 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.py53 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.py138 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.py95 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.py96 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.py116 def __init__(self, request_streaming, response_streaming, argument
119 self.request_streaming = request_streaming
D_interceptor_test.py116 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.py32 request_streaming = True variable in _MethodHandler
D_rpc_test.py120 def __init__(self, request_streaming, response_streaming, argument
123 self.request_streaming = request_streaming
/external/protobuf/php/src/Google/Protobuf/
DMethod.php35 protected $request_streaming = false; variable in Google\\Protobuf\\Method
148 return $this->request_streaming;
161 $this->request_streaming = $var;
/external/cronet/third_party/protobuf/php/src/Google/Protobuf/
DMethod.php35 protected $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/
Dapi.rs309 pub request_streaming: bool, field
353 |m: &Method| { &m.request_streaming }, in generated_message_descriptor_data()
354 |m: &mut Method| { &mut m.request_streaming }, in generated_message_descriptor_data()
401 self.request_streaming = is.read_bool()?; in merge_from()
433 if self.request_streaming != false { in compute_size()
461 if self.request_streaming != false { in write_to_with_cached_sizes()
462 os.write_bool(3, self.request_streaming)?; in write_to_with_cached_sizes()
495 self.request_streaming = false; in clear()
507 request_streaming: false, in default_instance()
/external/rust/crates/protobuf/2.27.1/src/well_known_types/
Dapi.rs467 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/
Dheader_manipulator_client_interceptor.py32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc126 auto request_streaming = std::bind( in AsyncQpsServerTest() local
131 request_streaming, process_rpc_bound)); in AsyncQpsServerTest()
/external/cronet/third_party/protobuf/src/google/protobuf/
Dapi.proto108 bool request_streaming = 3; field
Dapi.pb.h513 bool request_streaming() const; in Swap()
1163 inline bool Method::request_streaming() const { in request_streaming() function
/external/rust/crates/protobuf-parse/src/proto/google/protobuf/
Dapi.proto108 bool request_streaming = 3; field
/external/protobuf/src/google/protobuf/
Dapi.proto108 bool request_streaming = 3; field
Dapi.pb.h520 bool request_streaming() const; in Swap()
1178 inline bool Method::request_streaming() const { in request_streaming() function
/external/grpc-grpc/src/python/grpcio/grpc/
D_server.py599 if method_handler.request_streaming:
/external/protobuf/php/ext/google/protobuf/
Dwkt.inc453 intern->desc->msgdef, "request_streaming");
462 intern->desc->msgdef, "request_streaming");
/external/cronet/third_party/protobuf/php/ext/google/protobuf/
Dwkt.inc453 intern->desc->msgdef, "request_streaming");
462 intern->desc->msgdef, "request_streaming");