From bea8da8a5dab588022e3c368f30d7fba4104f406 Mon Sep 17 00:00:00 2001
From: alecmocatta <alec@mocatta.net>
Date: Tue, 4 Aug 2020 21:50:00 +0100
Subject: [PATCH] fix

---
 amadeus-core/src/par_pipe.rs   | 2 +-
 amadeus-core/src/par_stream.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/amadeus-core/src/par_pipe.rs b/amadeus-core/src/par_pipe.rs
index 72839e02..490fb8fc 100644
--- 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
index e2809291..f04d8f6b 100644
--- 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