diff options
Diffstat (limited to 'lib/entry/libimagentryview/src/viewer.rs')
-rw-r--r-- | lib/entry/libimagentryview/src/viewer.rs | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/lib/entry/libimagentryview/src/viewer.rs b/lib/entry/libimagentryview/src/viewer.rs index ca599e15..1fa2271c 100644 --- a/lib/entry/libimagentryview/src/viewer.rs +++ b/lib/entry/libimagentryview/src/viewer.rs @@ -130,8 +130,15 @@ impl<'a, I, V, W, F, T> Iterator for ViewIter<'a, I, V, W, F, T> fn next(&mut self) -> Option<Self::Item> { if let Some(next) = self.inner.next() { if let Some(entry) = (self.func)(&next) { - if let Err(e) = self.viewer.view_entry(&entry, self.sink) { - return Some(Err(e).map_err(failure::Error::from)) + let r = self.viewer.view_entry(&entry, self.sink); + trace!("Viewing resulted in {:?}", r); + match r { + Ok(_) => { /* nothing */ }, + Err(crate::error::Error::Io(ref e)) if e.kind() == std::io::ErrorKind::BrokenPipe => { + trace!("Stopping iteration, because of broken pipe error!"); + return None + }, + Err(e) => return Some(Err(failure::Error::from(e))) } } |