diff options
| author |  Héctor Ramón Jiménez <hector0193@gmail.com> | 2019-12-14 01:13:01 +0100 |
|---|---|---|
| committer | Héctor Ramón Jiménez <hector0193@gmail.com> | 2019-12-14 01:13:01 +0100 |
| commit | c688452d7beb1b17ef8416fc101f8868767fc457 (patch) | |
| tree | c2ef229276dcf9b4040bbeb70d048120f9738106 /core/src/subscription.rs | |
| parent | 69ed631d449e74b38054aa052c620368cb65c72c (diff) | |
| download | iced-c688452d7beb1b17ef8416fc101f8868767fc457.tar.gz iced-c688452d7beb1b17ef8416fc101f8868767fc457.tar.bz2 iced-c688452d7beb1b17ef8416fc101f8868767fc457.zip | |
Consume `Recipe` when building a `Stream`
Diffstat (limited to 'core/src/subscription.rs')
| -rw-r--r-- | core/src/subscription.rs | 4 |
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; |