(&mut self)
| 311 | } |
| 312 | |
| 313 | async fn wait_for_initial(&mut self) -> Result<()> { |
| 314 | if let DebuggeeState::Initial = &self.state { |
| 315 | // Need to receive and discard first `Paused`. |
| 316 | let response = self |
| 317 | .out_rx |
| 318 | .recv() |
| 319 | .await |
| 320 | .ok_or_else(|| wasmtime::format_err!("Premature close of debugger channel"))?; |
| 321 | assert!(matches!(response, Response::Paused(_))); |
| 322 | self.state = DebuggeeState::Paused; |
| 323 | } |
| 324 | Ok(()) |
| 325 | } |
| 326 | |
| 327 | /// Run the inner body until the next debug event. |
| 328 | /// |
no test coverage detected