DGNum/rust-irc
6
0
Fork 0
Code Issues 1 Pull requests 3 Projects Releases Packages Wiki Activity Actions

Made a stylistic change to the new message throttling code.

Browse source
This commit is contained in:
Aaron Weiss 2018-01-01 21:52:23 -05:00
parent 70ff2ec992
commit 68666aef09
No known key found for this signature in database
GPG key ID: 047D32DF25DC22EF
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/client/transport.rs
View file

@ -152,12 +152,9 @@ where
Err(error::ErrorKind::PingTimeout.into())
} else {
// Check if the oldest message in the rolling window is discounted.
match self.rolling_burst_window_front()? {
Async::NotReady => (),
Async::Ready(()) => {
self.current_burst_messages -= 1;
self.rolling_burst_window.pop_front();
}
if let Async::Ready(()) = self.rolling_burst_window_front()? {
self.current_burst_messages -= 1;
self.rolling_burst_window.pop_front();
}
// Throttling if too many messages have been sent recently.