fn next()

in ingester/src/main.rs [118:125]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    fn next(&mut self) -> Option<Self::Item> {
        self.line.clear();
        match self.reader.read_line(&mut self.line) {
            Ok(0) => None,
            Err(e) => Some(Err(e.into())),
            Ok(_) => Some(serde_json::from_str(&self.line).map_err(|e| e.into())),
        }
    }