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

Method flush

arrow-avro/src/reader/block.rs:130–138  ·  view source on GitHub ↗

Flush this decoder returning the parsed [`Block`] if any

(&mut self)

Source from the content-addressed store, hash-verified

128
129 /// Flush this decoder returning the parsed [`Block`] if any
130 pub fn flush(&mut self) -> Option<Block> {
131 match self.state {
132 BlockDecoderState::Finished => {
133 self.state = BlockDecoderState::Count;
134 Some(std::mem::take(&mut self.in_progress))
135 }
136 _ => None,
137 }
138 }
139}
140
141#[cfg(feature = "async")]

Callers

nothing calls this directly

Calls 1

takeFunction · 0.85

Tested by

no test coverage detected