From c688452d7beb1b17ef8416fc101f8868767fc457 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Sat, 14 Dec 2019 01:13:01 +0100
Subject: Consume `Recipe` when building a `Stream`

---
 core/src/subscription.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'core/src/subscription.rs')

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;
-- 
cgit