(&self, session_id: &str)
| 746 | } |
| 747 | |
| 748 | async fn finish_run(&self, session_id: &str) { |
| 749 | let mut state = self.state.lock().await; |
| 750 | state.remove(session_id); |
| 751 | drop(state); |
| 752 | |
| 753 | let mut session_state = self.session_state.write().await; |
| 754 | session_state.set_idle(session_id); |
| 755 | } |
| 756 | |
| 757 | pub async fn cancel(&self, session_id: &str) { |
| 758 | let mut state = self.state.lock().await; |
no test coverage detected