Method notify

core/src/mcp/transport/streamable_http.rs:312–337

(&self, notification: JsonRpcNotification)

    }

    async fn notify(&self, notification: JsonRpcNotification) -> Result<()> {
        if !self.connected.load(Ordering::SeqCst) {
            return Err(anyhow!("Transport not connected"));
        }

        let extra_headers = self.request_headers().await;
        let body = serde_json::to_string(&notification)?;

        let response = self
            .client
            .post(&self.url)
            .headers(extra_headers)
            .body(body)
            .send()
            .await
            .with_context(|| format!("Streamable HTTP notification to {} failed", self.url))?;

        if !response.status().is_success() {
            tracing::warn!(
                status = %response.status(),
                "Streamable HTTP notification returned non-success status"
            );
        }

        Ok(())
    }

    fn notifications(&self) -> mpsc::Receiver<McpNotification> {
        let mut rx = self.notification_rx.blocking_write();