fix

constellation-rs · Aug 4, 2020 · bea8da8 · bea8da8
1 parent 80beab2
commit bea8da8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/amadeus-core/src/par_pipe.rs b/amadeus-core/src/par_pipe.rs
@@ -215,7 +215,7 @@ macro_rules! pipe {
 			#[inline]
 			fn mean(self) -> Mean<Self>
 			where
-			Self: $pipe<Item =f64> + Sized, 
+			Self: $pipe<Input, Output = f64> + Sized,
 			{
 				$assert_sink(Mean::new(self))
 			}

diff --git a/amadeus-core/src/par_stream.rs b/amadeus-core/src/par_stream.rs
@@ -234,7 +234,7 @@ macro_rules! stream {
 				P: $pool,
 				Self::Item: 'static,
 				Self::Task: 'static,
-				Self: Sized,
+				Self: $stream<Item = f64> + Sized,
 			{
 				self.pipe(pool, $pipe::<Self::Item>::mean(Identity))
 				.await