@@ -63,6 +63,7 @@ pub enum StreamableHttpProtocolError {
6363 MissingSessionIdInResponse ,
6464}
6565
66+ #[ allow( clippy:: large_enum_variant) ]
6667pub enum StreamableHttpPostResponse {
6768 Accepted ,
6869 Json ( ServerJsonRpcMessage , Option < String > ) ,
@@ -557,7 +558,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
557558///
558559/// impl StreamableHttpClient for MyHttpClient {
559560/// type Error = MyError;
560- ///
561+ ///
561562/// async fn post_message(
562563/// &self,
563564/// _uri: Arc<str>,
@@ -567,7 +568,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
567568/// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
568569/// todo!()
569570/// }
570- ///
571+ ///
571572/// async fn delete_session(
572573/// &self,
573574/// _uri: Arc<str>,
@@ -576,7 +577,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
576577/// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
577578/// todo!()
578579/// }
579- ///
580+ ///
580581/// async fn get_stream(
581582/// &self,
582583/// _uri: Arc<str>,
@@ -639,7 +640,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
639640 ///
640641 /// impl StreamableHttpClient for MyHttpClient {
641642 /// type Error = MyError;
642- ///
643+ ///
643644 /// async fn post_message(
644645 /// &self,
645646 /// _uri: Arc<str>,
@@ -649,7 +650,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
649650 /// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
650651 /// todo!()
651652 /// }
652- ///
653+ ///
653654 /// async fn delete_session(
654655 /// &self,
655656 /// _uri: Arc<str>,
@@ -658,7 +659,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
658659 /// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
659660 /// todo!()
660661 /// }
661- ///
662+ ///
662663 /// async fn get_stream(
663664 /// &self,
664665 /// _uri: Arc<str>,
0 commit comments