(&mut self)
| 231 | } |
| 232 | |
| 233 | fn handle_tx_event(&mut self) -> result::Result<(), DeviceError> { |
| 234 | let rate_limit_reached = self |
| 235 | .net |
| 236 | .tx_rate_limiter |
| 237 | .as_ref() |
| 238 | .is_some_and(|r| r.is_blocked()); |
| 239 | |
| 240 | if !rate_limit_reached { |
| 241 | self.process_tx()?; |
| 242 | } |
| 243 | |
| 244 | Ok(()) |
| 245 | } |
| 246 | |
| 247 | fn handle_rx_tap_event(&mut self) -> result::Result<(), DeviceError> { |
| 248 | let res = self |
no test coverage detected