@@ -243,8 +243,12 @@ impl HttpTransport {
243243 let transport_config = StreamableHttpClientTransportConfig :: with_uri ( self . url . as_str ( ) ) ;
244244 let transport = StreamableHttpClientTransport :: with_client ( auth_client, transport_config) ;
245245
246- let client_handler =
247- create_client_handler ( & self . server_id , self . space_id , self . event_tx . clone ( ) , self . log_manager . clone ( ) ) ;
246+ let client_handler = create_client_handler (
247+ & self . server_id ,
248+ self . space_id ,
249+ self . event_tx . clone ( ) ,
250+ self . log_manager . clone ( ) ,
251+ ) ;
248252
249253 let connect_future = client_handler. serve ( transport) ;
250254 match tokio:: time:: timeout ( self . connect_timeout , connect_future) . await {
@@ -363,8 +367,12 @@ impl HttpTransport {
363367 let transport_config = StreamableHttpClientTransportConfig :: with_uri ( self . url . as_str ( ) ) ;
364368 let transport = StreamableHttpClientTransport :: with_client ( client, transport_config) ;
365369
366- let client_handler =
367- create_client_handler ( & self . server_id , self . space_id , self . event_tx . clone ( ) , self . log_manager . clone ( ) ) ;
370+ let client_handler = create_client_handler (
371+ & self . server_id ,
372+ self . space_id ,
373+ self . event_tx . clone ( ) ,
374+ self . log_manager . clone ( ) ,
375+ ) ;
368376
369377 let connect_future = client_handler. serve ( transport) ;
370378 match tokio:: time:: timeout ( self . connect_timeout , connect_future) . await {
@@ -430,8 +438,12 @@ impl HttpTransport {
430438 . await ;
431439
432440 let transport = StreamableHttpClientTransport :: from_uri ( self . url . as_str ( ) ) ;
433- let client_handler =
434- create_client_handler ( & self . server_id , self . space_id , self . event_tx . clone ( ) , self . log_manager . clone ( ) ) ;
441+ let client_handler = create_client_handler (
442+ & self . server_id ,
443+ self . space_id ,
444+ self . event_tx . clone ( ) ,
445+ self . log_manager . clone ( ) ,
446+ ) ;
435447
436448 let connect_future = client_handler. serve ( transport) ;
437449 match tokio:: time:: timeout ( self . connect_timeout , connect_future) . await {
0 commit comments