diff --git a/src/core/utils/stream/ignore.rs b/src/core/utils/stream/ignore.rs index 997aa4ba..4e426557 100644 --- a/src/core/utils/stream/ignore.rs +++ b/src/core/utils/stream/ignore.rs @@ -13,6 +13,15 @@ where T: Stream> + TryStream + Send + 'a, Item: Send + 'a, { + #[cfg(debug_assertions)] + #[inline] + fn ignore_err(self: T) -> impl Stream + Send + 'a { + use super::TryExpect; + + self.expect_ok() + } + + #[cfg(not(debug_assertions))] #[inline] fn ignore_err(self: T) -> impl Stream + Send + 'a { self.filter_map(|res| ready(res.ok())) }