(&mut self, buf: &[u8])
| 335 | |
| 336 | impl Decoder for CsvDecoder { |
| 337 | fn decode(&mut self, buf: &[u8]) -> Result<usize, ArrowError> { |
| 338 | self.inner.decode(buf) |
| 339 | } |
| 340 | |
| 341 | fn flush(&mut self) -> Result<Option<RecordBatch>, ArrowError> { |
| 342 | self.inner.flush() |
no outgoing calls
no test coverage detected