turul_http_mcp_server/
handler.rs

1//! SSE stream body utilities for MCP protocol
2//!
3//! McpHttpHandler has been removed in 0.2.0 - use SessionMcpHandler instead.
4//! This module now only contains the SseStreamBody utility for compatibility.
5
6use std::pin::Pin;
7use std::task::{Context, Poll};
8
9use bytes::Bytes;
10use futures::Stream;
11use http_body::Body;
12
13/// SSE stream body that implements hyper's Body trait
14pub struct SseStreamBody {
15    stream: Pin<
16        Box<
17            dyn Stream<Item = std::result::Result<String, tokio::sync::broadcast::error::RecvError>>
18                + Send,
19        >,
20    >,
21}
22
23impl SseStreamBody {
24    pub fn new<S>(stream: S) -> Self
25    where
26        S: Stream<Item = std::result::Result<String, tokio::sync::broadcast::error::RecvError>>
27            + Send
28            + 'static,
29    {
30        Self {
31            stream: Box::pin(stream),
32        }
33    }
34}
35
36impl Body for SseStreamBody {
37    type Data = Bytes;
38    type Error = Box<dyn std::error::Error + Send + Sync>;
39
40    fn poll_frame(
41        mut self: Pin<&mut Self>,
42        cx: &mut Context<'_>,
43    ) -> Poll<Option<std::result::Result<http_body::Frame<Self::Data>, Self::Error>>> {
44        match self.stream.as_mut().poll_next(cx) {
45            Poll::Ready(Some(Ok(data))) => {
46                let bytes = Bytes::from(data);
47                Poll::Ready(Some(Ok(http_body::Frame::data(bytes))))
48            }
49            Poll::Ready(Some(Err(e))) => Poll::Ready(Some(Err(Box::new(e)))),
50            Poll::Ready(None) => Poll::Ready(None),
51            Poll::Pending => Poll::Pending,
52        }
53    }
54}
55
56// McpHttpHandler removed in 0.2.0 - use SessionMcpHandler instead
57// All SSE functionality is now provided by SessionMcpHandler with proper streaming support
58
59// McpHttpHandler implementation removed - use SessionMcpHandler instead
60
61// Tests for McpHttpHandler removed - handler no longer exists
62// Use SessionMcpHandler tests in session_handler.rs instead
turul_http_mcp_server/handler.rs

turul_http_mcp_server/
handler.rs
