@@ -94,7 +94,7 @@ async fn connect(
9494 }
9595 Err ( err) => {
9696 set_disconnected_prompt ( interface) ;
97- writeln ! ( interface, "{}" , err ) . unwrap ( ) ;
97+ writeln ! ( interface, "{err}" ) . unwrap ( ) ;
9898 None
9999 }
100100 }
@@ -132,7 +132,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
132132
133133 let addr = std:: env:: var ( "KUKSA_DATA_BROKER_ADDR" ) . unwrap_or_else ( |_| "127.0.0.1" . to_owned ( ) ) ;
134134 let port = std:: env:: var ( "KUKSA_DATA_BROKER_PORT" ) . unwrap_or_else ( |_| "55555" . to_owned ( ) ) ;
135- let mut uri = match addr_to_uri ( format ! ( "{}:{}" , addr , port ) ) {
135+ let mut uri = match addr_to_uri ( format ! ( "{addr }:{port}" ) ) {
136136 Some ( uri) => uri,
137137 None => return Err ( Box :: new ( ParseError { } ) . into ( ) ) ,
138138 } ;
@@ -154,10 +154,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
154154 let ( cmd, args) = split_first_word ( & line) ;
155155 match cmd {
156156 "help" => {
157- println ! ( "{} commands:" , APP_NAME ) ;
157+ println ! ( "{APP_NAME } commands:" ) ;
158158 println ! ( ) ;
159159 for & ( cmd, help) in CLI_COMMANDS {
160- println ! ( " {:15} - {}" , cmd , help ) ;
160+ println ! ( " {cmd :15} - {help}" ) ;
161161 }
162162 println ! ( ) ;
163163 }
@@ -270,15 +270,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
270270 ) {
271271 Some ( error) => {
272272 println ! (
273- "-> Error setting id {}: {:?}" ,
274- id, error
273+ "-> Error setting id {id}: {error:?}" ,
275274 )
276275 }
277276 None => {
278- println ! (
279- "-> Error setting id {}" ,
280- id
281- )
277+ println ! ( "-> Error setting id {id}" )
282278 }
283279 }
284280 }
@@ -367,15 +363,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
367363 ) {
368364 Some ( error) => {
369365 println ! (
370- "-> Error setting id {}: {:?}" ,
371- id, error
366+ "-> Error setting id {id}: {error:?}"
372367 )
373368 }
374369 None => {
375- println ! (
376- "-> Error setting id {}" ,
377- id
378- )
370+ println ! ( "-> Error setting id {id}" )
379371 }
380372 }
381373 }
@@ -417,8 +409,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
417409 tonic:: Request :: new ( proto:: v1:: SubscribeRequest { query } ) ;
418410 match client. subscribe ( args) . await {
419411 Ok ( response) => {
420- let sub_id =
421- format ! ( "subscription{}" , subscription_nbr) ;
412+ let sub_id = format ! ( "subscription{subscription_nbr}" ) ;
422413 subscription_nbr += 1 ;
423414 tokio:: spawn ( async move {
424415 let mut stream = response. into_inner ( ) ;
@@ -441,8 +432,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
441432 }
442433 writeln ! (
443434 iface,
444- "-> {}:\n {}" ,
445- sub_id, output
435+ "-> {sub_id}:\n {output}"
446436 )
447437 . unwrap ( ) ;
448438 }
@@ -531,7 +521,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
531521 break ;
532522 }
533523 ReadResult :: Signal ( sig) => {
534- println ! ( "received signal: {:?}" , sig ) ;
524+ println ! ( "received signal: {sig :?}" ) ;
535525 }
536526 }
537527 }
@@ -778,9 +768,9 @@ where
778768 let real_delimiter = ", " ;
779769 let mut delimiter = "" ;
780770 for value in array {
781- write ! ( f, "{}" , delimiter ) ?;
771+ write ! ( f, "{delimiter}" ) ?;
782772 delimiter = real_delimiter;
783- write ! ( f, "{}" , value ) ?;
773+ write ! ( f, "{value}" ) ?;
784774 }
785775 f. write_str ( "]" )
786776}
@@ -790,32 +780,32 @@ impl fmt::Display for DisplayDatapoint {
790780 match & self . 0 . value {
791781 Some ( value) => match value {
792782 proto:: v1:: datapoint:: Value :: BoolValue ( value) => {
793- f. write_fmt ( format_args ! ( "{}" , value ) )
783+ f. write_fmt ( format_args ! ( "{value}" ) )
794784 }
795785 proto:: v1:: datapoint:: Value :: FailureValue ( failure) => f. write_fmt ( format_args ! (
796786 "( {:?} )" ,
797787 proto:: v1:: datapoint:: Failure :: from_i32( * failure) . unwrap( )
798788 ) ) ,
799789 proto:: v1:: datapoint:: Value :: Int32Value ( value) => {
800- f. write_fmt ( format_args ! ( "{}" , value ) )
790+ f. write_fmt ( format_args ! ( "{value}" ) )
801791 }
802792 proto:: v1:: datapoint:: Value :: Int64Value ( value) => {
803- f. write_fmt ( format_args ! ( "{}" , value ) )
793+ f. write_fmt ( format_args ! ( "{value}" ) )
804794 }
805795 proto:: v1:: datapoint:: Value :: Uint32Value ( value) => {
806- f. write_fmt ( format_args ! ( "{}" , value ) )
796+ f. write_fmt ( format_args ! ( "{value}" ) )
807797 }
808798 proto:: v1:: datapoint:: Value :: Uint64Value ( value) => {
809- f. write_fmt ( format_args ! ( "{}" , value ) )
799+ f. write_fmt ( format_args ! ( "{value}" ) )
810800 }
811801 proto:: v1:: datapoint:: Value :: FloatValue ( value) => {
812- f. write_fmt ( format_args ! ( "{:.2}" , value ) )
802+ f. write_fmt ( format_args ! ( "{value :.2}" ) )
813803 }
814804 proto:: v1:: datapoint:: Value :: DoubleValue ( value) => {
815- f. write_fmt ( format_args ! ( "{}" , value ) )
805+ f. write_fmt ( format_args ! ( "{value}" ) )
816806 }
817807 proto:: v1:: datapoint:: Value :: StringValue ( value) => {
818- f. write_fmt ( format_args ! ( "'{}'" , value ) )
808+ f. write_fmt ( format_args ! ( "'{value }'" ) )
819809 }
820810 proto:: v1:: datapoint:: Value :: StringArray ( array) => display_array ( f, & array. values ) ,
821811 proto:: v1:: datapoint:: Value :: BoolArray ( array) => display_array ( f, & array. values ) ,
0 commit comments