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

Method array

src/interchange/src/avro/decode.rs:408–426  ·  view source on GitHub ↗
(mut self, a: &mut A)

Source from the content-addressed store, hash-verified

406 }
407 #[inline]
408 fn array<A: AvroArrayAccess>(mut self, a: &mut A) -> Result<Self::Out, AvroError> {
409 self.is_top = false;
410 let mut str_buf = std::mem::take(self.buf);
411 self.packer.push_list_with(|rp| -> Result<(), AvroError> {
412 loop {
413 let next = AvroFlatDecoder {
414 packer: rp,
415 buf: &mut str_buf,
416 is_top: false,
417 };
418 if a.decode_next(next)?.is_none() {
419 break;
420 }
421 }
422 Ok(())
423 })?;
424 *self.buf = str_buf;
425 Ok(())
426 }
427 #[inline]
428 fn map<A: AvroMapAccess>(self, a: &mut A) -> Result<Self::Out, AvroError> {
429 // Map (key, value) pairs need to be unique and ordered.

Callers

nothing calls this directly

Calls 4

takeFunction · 0.85
push_list_withMethod · 0.80
is_noneMethod · 0.80
decode_nextMethod · 0.80

Tested by

no test coverage detected