Method close

core/src/mcp/transport/streamable_http.rs:347–365

(&self)

    }

    async fn close(&self) -> Result<()> {
        self.connected.store(false, Ordering::SeqCst);

        // Send DELETE to terminate session if we have a session ID
        if let Some(ref sid) = *self.session_id.read().await {
            let mut headers = reqwest::header::HeaderMap::new();
            if let Ok(val) = reqwest::header::HeaderValue::from_str(sid) {
                headers.insert("Mcp-Session-Id", val);
            }
            let _ = self.client.delete(&self.url).headers(headers).send().await;
        }

        let mut abort = self.sse_abort.write().await;
        if let Some(handle) = abort.take() {
            handle.abort();
        }

        Ok(())
    }

    fn is_connected(&self) -> bool {
        self.connected.load(Ordering::SeqCst)