diff options
| -rw-r--r-- | core/src/subscription.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/subscription.rs b/core/src/subscription.rs index 3ba5e629..21868c20 100644 --- a/core/src/subscription.rs +++ b/core/src/subscription.rs @@ -115,7 +115,7 @@ where ) -> futures::stream::BoxStream<'static, Self::Output> { use futures::StreamExt; - let mapper = self.mapper.clone(); + let mapper = self.mapper; self.recipe .stream(input) |