(&self, session_id: &str)
| 162 | } |
| 163 | |
| 164 | pub async fn assert_not_busy(&self, session_id: &str) -> anyhow::Result<()> { |
| 165 | let state = self.state.lock().await; |
| 166 | if state.contains_key(session_id) { |
| 167 | return Err(anyhow::anyhow!("Session {} is busy", session_id)); |
| 168 | } |
| 169 | Ok(()) |
| 170 | } |
| 171 | |
| 172 | pub async fn create_user_message( |
| 173 | &self, |
no outgoing calls
no test coverage detected