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