(&self, err: ParcodeError)
| 43 | W: Write + Send, |
| 44 | { |
| 45 | fn signal_error(&self, err: ParcodeError) { |
| 46 | let mut guard = self.error_capture.lock().unwrap_or_else(|p| p.into_inner()); |
| 47 | if guard.is_none() { |
| 48 | *guard = Some(err); |
| 49 | self.abort_flag.store(true, Ordering::SeqCst); |
| 50 | } |
| 51 | } |
| 52 | |
| 53 | fn should_abort(&self) -> bool { |
| 54 | self.abort_flag.load(Ordering::Relaxed) |
no test coverage detected