(&self, session_id: &str)
| 736 | } |
| 737 | |
| 738 | async fn resume(&self, session_id: &str) -> Option<CancellationToken> { |
| 739 | let state = self.state.lock().await; |
| 740 | state.get(session_id).map(|s| s.cancel_token.clone()) |
| 741 | } |
| 742 | |
| 743 | pub async fn is_running(&self, session_id: &str) -> bool { |
| 744 | let state = self.state.lock().await; |
no test coverage detected