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

Method fill_buf

src/avro/src/reader.rs:255–264  ·  view source on GitHub ↗
(&mut self, n: usize)

Source from the content-addressed store, hash-verified

253 }
254
255 fn fill_buf(&mut self, n: usize) -> Result<(), AvroError> {
256 // We don't have enough space in the buffer, need to grow it.
257 if n >= self.buf.len() {
258 self.buf.resize(n, 0);
259 }
260
261 self.inner.read_exact(&mut self.buf[..n])?;
262 self.buf_idx = 0;
263 Ok(())
264 }
265
266 fn read_block_next(&mut self) -> Result<(), AvroError> {
267 assert!(self.is_empty(), "Expected self to be empty!");

Callers 1

read_block_nextMethod · 0.80

Calls 2

resizeMethod · 0.80
lenMethod · 0.45

Tested by

no test coverage detected