We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 82be994 commit 76b815fCopy full SHA for 76b815f
src/stream/interval.rs
@@ -72,7 +72,7 @@ impl Stream for Interval {
72
return Poll::Pending;
73
}
74
let interval = self.interval;
75
- std::mem::replace(&mut self.delay, Timer::after(interval));
+ let _ = std::mem::replace(&mut self.delay, Timer::after(interval));
76
Poll::Ready(Some(()))
77
78
src/stream/stream/throttle.rs
@@ -59,7 +59,7 @@ impl<S: Stream> Stream for Throttle<S> {
59
Poll::Ready(None) => Poll::Ready(None),
60
Poll::Ready(Some(v)) => {
61
*this.blocked = true;
62
- std::mem::replace(&mut *this.delay, Timer::after(*this.duration));
+ let _ = std::mem::replace(&mut *this.delay, Timer::after(*this.duration));
63
Poll::Ready(Some(v))
64
65
0 commit comments