Remove unnecessary clone in subscription::Map

This commit is contained in:
Héctor Ramón Jiménez 2019-12-14 03:57:04 +01:00
parent c13ef73e8b
commit e71978456a

View file

@ -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)