File tree Expand file tree Collapse file tree 1 file changed +3
-12
lines changed
crates/rmcp/src/transport Expand file tree Collapse file tree 1 file changed +3
-12
lines changed Original file line number Diff line number Diff line change @@ -67,10 +67,7 @@ impl From<reqwest::Error> for SseTransportError<reqwest::Error> {
6767}
6868
6969pub trait SseClient < E : std:: error:: Error + Send + Sync > : Clone + Send + Sync + ' static {
70- fn connect (
71- & self ,
72- last_event_id : Option < String > ,
73- ) -> SseStreamFuture < E > ;
70+ fn connect ( & self , last_event_id : Option < String > ) -> SseStreamFuture < E > ;
7471
7572 fn post (
7673 & self ,
@@ -134,10 +131,7 @@ impl ReqwestSseClient {
134131}
135132
136133impl SseClient < reqwest:: Error > for ReqwestSseClient {
137- fn connect (
138- & self ,
139- last_event_id : Option < String > ,
140- ) -> SseStreamFuture < reqwest:: Error > {
134+ fn connect ( & self , last_event_id : Option < String > ) -> SseStreamFuture < reqwest:: Error > {
141135 let client = self . http_client . clone ( ) ;
142136 let sse_url = self . sse_url . as_ref ( ) . to_string ( ) ;
143137 let last_event_id = last_event_id. clone ( ) ;
@@ -244,10 +238,7 @@ impl<C: SseClient<E>, E: std::error::Error + Send + Sync + 'static> SseTransport
244238 } )
245239 }
246240
247- fn retry_connection (
248- & self ,
249- ) -> SseStreamFuture < E >
250- {
241+ fn retry_connection ( & self ) -> SseStreamFuture < E > {
251242 let retry_duration = {
252243 let recommended_retry_duration = self
253244 . recommended_retry_duration_ms
You can’t perform that action at this time.
0 commit comments