MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / decode_next

Method decode_next

src/avro/src/decode.rs:907–916  ·  view source on GitHub ↗
(&mut self, d: D)

Source from the content-addressed store, hash-verified

905
906impl<'a> AvroArrayAccess for ValueArrayAccess<'a> {
907 fn decode_next<D: AvroDecode>(&mut self, d: D) -> Result<Option<D::Out>, AvroError> {
908 assert!(self.i <= self.values.len());
909 if self.i == self.values.len() {
910 Ok(None)
911 } else {
912 let val = give_value(d, &self.values[self.i])?;
913 self.i += 1;
914 Ok(Some(val))
915 }
916 }
917}
918
919/// Sanity cap on the number of `Value` nodes one top-level decode may

Callers 3

arrayMethod · 0.80
arrayMethod · 0.80

Calls 10

give_valueFunction · 0.85
zag_i64Function · 0.85
decode_lenFunction · 0.85
charge_value_nodesFunction · 0.85
min_encoded_lenFunction · 0.85
saturating_mulMethod · 0.80
lenMethod · 0.45
remaining_inputMethod · 0.45
mapMethod · 0.45
deserializeMethod · 0.45

Tested by

no test coverage detected