@@ -58,7 +58,7 @@ async fn logs_tokio_helper(is_simple: bool, log_send_outside_rt: bool) -> Result
5858 {
5959 let clone_uuid = expected_uuid. clone ( ) ;
6060 if log_send_outside_rt {
61- std:: thread:: spawn ( move || {
61+ std:: thread:: spawn ( move || {
6262 let subscriber = tracing_subscriber:: registry ( ) . with ( layer) ;
6363 let _guard = tracing:: subscriber:: set_default ( subscriber) ;
6464 info ! (
@@ -68,7 +68,9 @@ async fn logs_tokio_helper(is_simple: bool, log_send_outside_rt: bool) -> Result
6868 "banana" ,
6969 2.99
7070 ) ;
71- } ) . join ( ) . unwrap ( ) ;
71+ } )
72+ . join ( )
73+ . unwrap ( ) ;
7274 } else {
7375 let subscriber = tracing_subscriber:: registry ( ) . with ( layer) ;
7476 let _guard = tracing:: subscriber:: set_default ( subscriber) ;
@@ -293,7 +295,11 @@ mod logtests {
293295 // Client - hyper, tonic, reqwest
294296 #[ ignore] // request, tonic and hyper client does not work without tokio runtime
295297 #[ test]
296- #[ cfg( any( feature = "hyper-client" , feature = "tonic-client" , feature = "reqwest-client" ) ) ]
298+ #[ cfg( any(
299+ feature = "hyper-client" ,
300+ feature = "tonic-client" ,
301+ feature = "reqwest-client"
302+ ) ) ]
297303 pub fn logs_simple_non_tokio_main_with_init_logs_outsie_rt ( ) -> Result < ( ) > {
298304 logs_non_tokio_helper ( true , false )
299305 }
@@ -351,8 +357,6 @@ mod logtests {
351357 pub async fn logs_simple_tokio_current ( ) -> Result < ( ) > {
352358 logs_tokio_helper ( true , false ) . await
353359 }
354-
355-
356360}
357361///
358362/// Make sure we stop the collector container, otherwise it will sit around hogging our
0 commit comments