Consume Recipe when building a Stream

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;

examples/events.rs

@@ -108,7 +108,7 @@ mod events {
         }
 
         fn stream(
-            &self,
+            self: Box<Self>,
             input: iced_native::subscription::Input,
         ) -> futures::stream::BoxStream<'static, Self::Output> {
             use futures::StreamExt;

examples/stopwatch.rs

@@ -167,7 +167,7 @@ mod time {
         }
 
         fn stream(
-            &self,
+            self: Box<Self>,
             _input: Input,
         ) -> futures::stream::BoxStream<'static, Self::Output> {
             use futures::stream::StreamExt;

winit/src/application.rs

@@ -470,6 +470,7 @@ impl Subscriptions {
 
                 let stream = recipe.stream(event_receiver);
 
+                // TODO: Find out how to avoid using a mutex here
                 let proxy =
                     std::sync::Arc::new(std::sync::Mutex::new(proxy.clone()));