in protobuf/src/internal.rs [139:152]
fn from_reader(r: &mut BytesReader, bytes: &'a [u8]) -> Result<Self> {
let mut msg = Self::default();
while !r.is_eof() {
match r.next_tag(bytes) {
Ok(10) => msg.logs.push(r.read_message::<internal::Log>(bytes)?),
Ok(26) => msg.topic = Some(r.read_string(bytes).map(Cow::Borrowed)?),
Ok(34) => msg.source = Some(r.read_string(bytes).map(Cow::Borrowed)?),
Ok(50) => msg.log_tags.push(r.read_message::<internal::LogTag>(bytes)?),
Ok(t) => { r.read_unknown(bytes, t)?; }
Err(e) => return Err(e),
}
}
Ok(msg)
}