[READ-ONLY] Mirror of https://github.com/probablykasper/csv-pipeline.
Add `PipelineIter::run`
+8
+8
src/pipeline.rs
+8
src/pipeline.rs
···
152
152
}
153
153
None
154
154
}
155
+
156
+
/// Run through the whole iterator. Returns the first error found, if any
157
+
pub fn run(&mut self) -> Result<(), Error> {
158
+
while let Some(item) = self.next() {
159
+
item?;
160
+
}
161
+
Ok(())
162
+
}
155
163
}
156
164
impl<'a> Iterator for PipelineIter<'a> {
157
165
type Item = RowResult;