chore(core): even more sync remove

vmenge · Dec 30, 2024 · 32d0875 · 32d0875
1 parent d912e81
commit 32d0875
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/core/src/lib.rs b/core/src/lib.rs
@@ -368,12 +368,11 @@ where
 
     pub fn stream<F, Fut, S, T, E>(&mut self, f: F) -> StreamBuilder<'_, P, F, Fut, S, T, E, NoSink>
     where
-        F: Fn() -> Fut + Send + Sync + 'static,
+        F: Fn() -> Fut + Send + 'static,
         Fut: Future<Output = S> + Send + 'static,
         S: Stream<Item = Result<T, E>> + Send + 'static + Unpin,
-        T: Send + Sync + 'static,
+        T: Send + 'static,
         E: Send + Sync + 'static,
-        P::Msg: Sync,
     {
         StreamBuilder::new(f, self)
     }

diff --git a/core/src/stream.rs b/core/src/stream.rs
@@ -118,10 +118,10 @@ where
 impl<'a, P, F, Fut, S, T, E> StreamBuilder<'a, P, F, Fut, S, T, E, NoSink>
 where
     P: Process,
-    F: Fn() -> Fut + Send + Sync + 'static,
+    F: Fn() -> Fut + Send + 'static,
     Fut: Future<Output = S> + Send + 'static,
     S: Stream<Item = Result<T, E>> + Send + 'static + Unpin,
-    T: Send + Sync + 'static,
+    T: Send + 'static,
     E: Send + Sync + 'static,
 {
     pub fn new(init: F, ctx: &'a mut Ctx<P>) -> Self {