From 338fff35ac821e6b03d68bd94418de500fb50f77 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Thu, 26 Mar 2020 14:55:02 +0100
Subject: Make `subscription::Recipe` cross-platform

By removing the `Send` requirement when targetting Wasm
---
 futures/src/subscription.rs | 34 +++++++++++++++-------------------
 1 file changed, 15 insertions(+), 19 deletions(-)

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

diff --git a/futures/src/subscription.rs b/futures/src/subscription.rs
index 8eccb7be..ab333a20 100644
--- a/futures/src/subscription.rs
+++ b/futures/src/subscription.rs
@@ -3,7 +3,7 @@ mod tracker;
 
 pub use tracker::Tracker;
 
-use futures::stream::BoxStream;
+use crate::BoxStream;
 
 /// A request to listen to external events.
 ///
@@ -168,8 +168,8 @@ pub trait Recipe<Hasher: std::hash::Hasher, Event> {
     /// [`Recipe`]: trait.Recipe.html
     fn stream(
         self: Box<Self>,
-        input: BoxStream<'static, Event>,
-    ) -> BoxStream<'static, Self::Output>;
+        input: BoxStream<Event>,
+    ) -> BoxStream<Self::Output>;
 }
 
 struct Map<Hasher, Event, A, B> {
@@ -201,18 +201,16 @@ where
         self.recipe.hash(state);
     }
 
-    fn stream(
-        self: Box<Self>,
-        input: BoxStream<'static, E>,
-    ) -> futures::stream::BoxStream<'static, Self::Output> {
+    fn stream(self: Box<Self>, input: BoxStream<E>) -> BoxStream<Self::Output> {
         use futures::StreamExt;
 
         let mapper = self.mapper;
 
-        self.recipe
-            .stream(input)
-            .map(move |element| mapper(element))
-            .boxed()
+        Box::pin(
+            self.recipe
+                .stream(input)
+                .map(move |element| mapper(element)),
+        )
     }
 }
 
@@ -243,17 +241,15 @@ where
         self.recipe.hash(state);
     }
 
-    fn stream(
-        self: Box<Self>,
-        input: BoxStream<'static, E>,
-    ) -> futures::stream::BoxStream<'static, Self::Output> {
+    fn stream(self: Box<Self>, input: BoxStream<E>) -> BoxStream<Self::Output> {
         use futures::StreamExt;
 
         let value = self.value;
 
-        self.recipe
-            .stream(input)
-            .map(move |element| (value.clone(), element))
-            .boxed()
+        Box::pin(
+            self.recipe
+                .stream(input)
+                .map(move |element| (value.clone(), element)),
+        )
     }
 }
-- 
cgit