|
|
@ -34,10 +34,10 @@ where
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
impl<L: Stream, R: Stream> Future for EqFuture<L, R>
|
|
|
|
impl<L: Stream, R: Stream> Future for EqFuture<L, R>
|
|
|
|
where
|
|
|
|
where
|
|
|
|
L: Stream + Sized,
|
|
|
|
L: Stream + Sized,
|
|
|
|
R: Stream + Sized,
|
|
|
|
R: Stream + Sized,
|
|
|
|
L::Item: PartialEq<R::Item>,
|
|
|
|
L::Item: PartialEq<R::Item>,
|
|
|
|
{
|
|
|
|
{
|
|
|
|
type Output = bool;
|
|
|
|
type Output = bool;
|
|
|
|
|
|
|
|
|
|
|
@ -53,8 +53,10 @@ impl<L: Stream, R: Stream> Future for EqFuture<L, R>
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
match (l_val, r_val) {
|
|
|
|
match (l_val, r_val) {
|
|
|
|
(Some(l), Some(r)) if l != r => {return Poll::Ready(false);},
|
|
|
|
(Some(l), Some(r)) if l != r => {
|
|
|
|
_ => {},
|
|
|
|
return Poll::Ready(false);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
_ => {}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|