chore(core): stream only send

core/src/stream.rs

@@ -25,8 +25,8 @@ struct Props<F, Snk> {
 impl<F, Fut, S, T, E, Snk> Process for Source<F, Fut, S, T, E, Snk>
 where
     F: Fn() -> Fut + Send + Sync + 'static,
-    Fut: Future<Output = S> + Send + Sync + 'static,
-    S: Stream<Item = Result<T, E>> + Send + Sync + 'static + Unpin,
+    Fut: Future<Output = S> + Send +  'static,
+    S: Stream<Item = Result<T, E>> + Send + 'static + Unpin,
     T: Send + Sync + 'static,
     E: Send + Sync + 'static,
     Snk: Sink<T> + Send + Sync + 'static,
@@ -118,11 +118,11 @@ where
 impl<'a, P, F, Fut, S, T, E> StreamBuilder<'a, P, F, Fut, S, T, E, NoSink>
 where
     P: Process,
-    F: Fn() -> Fut +   'static,
-    Fut: Future<Output = S> +   'static,
+    F: Fn() -> Fut + 'static,
+    Fut: Future<Output = S> + 'static,
     S: Stream<Item = Result<T, E>> + 'static + Unpin,
-    T:   'static,
-    E:   'static,
+    T: 'static,
+    E: 'static,
 {
     pub fn new(init: F, ctx: &'a mut Ctx<P>) -> Self {
         Self {
@@ -170,7 +170,7 @@ where
 
 impl<T, K> Sink<K> for Handle<T>
 where
-    T:  Send,
+    T: Send,
     K: Sync + Send + Into<T>,
 {
     async fn consume(&self, item: K) {
@@ -210,4 +210,4 @@ where
         let k: T = item.into();
         let _ = self.send(k);
     }
-}
+}