(&mut self)
| 17 | |
| 18 | impl WorkerState { |
| 19 | fn check_error(&mut self) -> Result<(), StreamError> { |
| 20 | if let Some(e) = self.error.take() { |
| 21 | return Err(StreamError::LastOperationFailed(e)); |
| 22 | } |
| 23 | if !self.alive { |
| 24 | return Err(StreamError::Closed); |
| 25 | } |
| 26 | Ok(()) |
| 27 | } |
| 28 | } |
| 29 | |
| 30 | struct Worker { |
no test coverage detected