This commit is contained in:
2026-06-12 15:48:03 +02:00
parent 00a93527de
commit c676e8e650

View File

@ -59,11 +59,7 @@ where
fn next(&mut self) -> Option<Self::Item> {
match self.inner.next()? {
Ok(chunk) => {
// self.process_chunk(&mut chunk);
// Some(Ok(chunk))
Some(Ok(self.process_chunk(&chunk)))
}
Ok(chunk) => Some(Ok(self.process_chunk(&chunk))),
Err(e) => Some(Err(e)),
}
}