1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/subscription.rs b/core/src/subscription.rs
index e9559f3c..3ba5e629 100644
--- a/core/src/subscription.rs
+++ b/core/src/subscription.rs
@@ -75,7 +75,7 @@ pub trait Recipe<Hasher: std::hash::Hasher, Input> {
     fn hash(&self, state: &mut Hasher);
 
     fn stream(
-        &self,
+        self: Box<Self>,
         input: Input,
     ) -> futures::stream::BoxStream<'static, Self::Output>;
 }
@@ -110,7 +110,7 @@ where
     }
 
     fn stream(
-        &self,
+        self: Box<Self>,
         input: I,
     ) -> futures::stream::BoxStream<'static, Self::Output> {
         use futures::StreamExt;