(&self)
| 64 | Ok(state.write_budget) |
| 65 | } |
| 66 | fn state(&self) -> std::sync::MutexGuard<'_, WorkerState> { |
| 67 | self.state.lock().unwrap() |
| 68 | } |
| 69 | fn pop(&self) -> Option<Job> { |
| 70 | let mut state = self.state(); |
| 71 | if state.items.is_empty() { |
no test coverage detected