Searched refs:read_message (Results 1 – 9 of 9) sorted by relevance
294 is.read_message::<M>() in parse_length_delimited_from()303 r.with_coded_input_stream(|is| is.read_message::<M>()) in parse_length_delimited_from_reader()311 bytes.with_coded_input_stream(|is| is.read_message::<M>()) in parse_length_delimited_from_bytes()
653 is.read_message() in read()
709 pub fn read_message<M: Message>(&mut self) -> ProtobufResult<M> { in read_message() method
201 string read_message; in TEST_P() local202 s = forward_op.attrs.Get("message", &read_message); in TEST_P()204 ASSERT_EQ(read_message, message); in TEST_P()
10 fn read_message(&mut self) -> std::result::Result<Option<PowerData>, Box<dyn Error>>; in read_message() method
136 fn read_message(&mut self) -> std::result::Result<Option<PowerData>, Box<dyn Error>> { in read_message() method
483 … self.kind = ::std::option::Option::Some(Value_oneof_kind::struct_value(is.read_message()?)); in merge_from()489 … self.kind = ::std::option::Option::Some(Value_oneof_kind::list_value(is.read_message()?)); in merge_from()
241 let data = match power_monitor.as_mut().unwrap().read_message() { in command_monitor()
131 static grpc_byte_buffer* read_message(input_stream* inp) { in read_message() function993 op->data.send_message.send_message = read_message(&inp); in LLVMFuzzerTestOneInput()