MCPcopy Create free account
hub / github.com/apache/arrow-rs / start_flushing

Method start_flushing

arrow-avro/src/reader/async_reader/mod.rs:224–226  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

222
223 #[inline]
224 fn start_flushing(&mut self) {
225 self.reader_state = ReaderState::Flushing;
226 }
227
228 /// Drain any remaining buffered records from the decoder.
229 #[inline]

Callers 1

read_nextMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected