(&self)
| 620 | } |
| 621 | |
| 622 | pub async fn close(&self) -> Result<(), McpClientError> { |
| 623 | let mut transport = self.transport.lock().await; |
| 624 | if let Some(t) = transport.as_ref() { |
| 625 | t.close().await?; |
| 626 | } |
| 627 | *transport = None; |
| 628 | |
| 629 | self.tool_registry.clear_server(&self.server_name).await; |
| 630 | self.set_status(McpStatus::Disabled).await; |
| 631 | |
| 632 | Ok(()) |
| 633 | } |
| 634 | |
| 635 | pub fn server_name(&self) -> &str { |
| 636 | &self.server_name |
no test coverage detected