|
|
|
@ -22,7 +22,7 @@ pin_project! {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
impl<L: Stream, R: Stream> NeFuture<L, R>
|
|
|
|
|
where
|
|
|
|
|
where
|
|
|
|
|
L::Item: PartialEq<R::Item>,
|
|
|
|
|
{
|
|
|
|
|
pub(super) fn new(l: L, r: R) -> Self {
|
|
|
|
@ -34,7 +34,7 @@ impl<L: Stream, R: Stream> NeFuture<L, R>
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
impl<L: Stream, R: Stream> Future for NeFuture<L, R>
|
|
|
|
|
where
|
|
|
|
|
where
|
|
|
|
|
L: Stream + Sized,
|
|
|
|
|
R: Stream + Sized,
|
|
|
|
|
L::Item: PartialEq<R::Item>,
|
|
|
|
@ -53,10 +53,13 @@ impl<L: Stream, R: Stream> Future for NeFuture<L, R>
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
match (l_val, r_val) {
|
|
|
|
|
(Some(l), Some(r)) if l == r => {continue;},
|
|
|
|
|
_ => { return Poll::Ready(true); },
|
|
|
|
|
(Some(l), Some(r)) if l == r => {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
_ => {
|
|
|
|
|
return Poll::Ready(true);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|