diff options
Diffstat (limited to 'src/purgatory/sync/throttle.rs')
| -rw-r--r-- | src/purgatory/sync/throttle.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/purgatory/sync/throttle.rs b/src/purgatory/sync/throttle.rs index 05b0878..e6efe1f 100644 --- a/src/purgatory/sync/throttle.rs +++ b/src/purgatory/sync/throttle.rs | |||
| @@ -152,7 +152,7 @@ impl DomainThrottle { | |||
| 152 | while self | 152 | while self |
| 153 | .request_times | 153 | .request_times |
| 154 | .front() | 154 | .front() |
| 155 | .map_or(false, |t| now.duration_since(*t) >= window) | 155 | .is_some_and(|t| now.duration_since(*t) >= window) |
| 156 | { | 156 | { |
| 157 | self.request_times.pop_front(); | 157 | self.request_times.pop_front(); |
| 158 | } | 158 | } |
| @@ -299,7 +299,7 @@ impl ThrottleManager { | |||
| 299 | /// Returns true if the domain has no capacity for another request, | 299 | /// Returns true if the domain has no capacity for another request, |
| 300 | /// either due to concurrent limit or rate limit. | 300 | /// either due to concurrent limit or rate limit. |
| 301 | pub fn is_throttled(&self, domain: &str) -> bool { | 301 | pub fn is_throttled(&self, domain: &str) -> bool { |
| 302 | self.throttles.get(domain).map_or(false, |entry| { | 302 | self.throttles.get(domain).is_some_and(|entry| { |
| 303 | let throttle = entry.lock().unwrap(); | 303 | let throttle = entry.lock().unwrap(); |
| 304 | !throttle.has_capacity() | 304 | !throttle.has_capacity() |
| 305 | }) | 305 | }) |