Consumes any pending signals so they don't affect future executions.
(&mut self)
| 166 | |
| 167 | /// Consumes any pending signals so they don't affect future executions. |
| 168 | pub fn drain_signals(&mut self) { |
| 169 | while self.signals_chan.1.try_recv().is_ok() { |
| 170 | // Do nothing. |
| 171 | } |
| 172 | } |
| 173 | |
| 174 | /// Returns true if execution should stop because we have hit a stop condition. |
| 175 | fn should_stop(&mut self) -> bool { |