(&self, session_id: &str)
| 718 | } |
| 719 | |
| 720 | async fn start(&self, session_id: &str) -> Option<CancellationToken> { |
| 721 | let state = self.state.lock().await; |
| 722 | if state.contains_key(session_id) { |
| 723 | return None; |
| 724 | } |
| 725 | drop(state); |
| 726 | |
| 727 | let token = CancellationToken::new(); |
| 728 | let mut state = self.state.lock().await; |
| 729 | state.insert( |
| 730 | session_id.to_string(), |
| 731 | PromptState { |
| 732 | cancel_token: token.clone(), |
| 733 | }, |
| 734 | ); |
| 735 | Some(token) |
| 736 | } |
| 737 | |
| 738 | async fn resume(&self, session_id: &str) -> Option<CancellationToken> { |
| 739 | let state = self.state.lock().await; |
no test coverage detected