@@ -88,9 +88,15 @@ async fn try_handle_publisher(
8888 ) {
8989 Ok ( ( data, _) ) => {
9090 let source_timestamp = MessageField :: some ( Timestamp {
91- #[ allow( clippy:: cast_possible_wrap, reason = "Unix seconds won't wrap any time soon" ) ]
91+ #[ allow(
92+ clippy:: cast_possible_wrap,
93+ reason = "Unix seconds won't wrap any time soon"
94+ ) ]
9295 seconds : ( data. source_timestamp_us . 0 / 1_000_000 ) as i64 ,
93- #[ allow( clippy:: cast_possible_truncation, reason = "this value will always be less than one billion" ) ]
96+ #[ allow(
97+ clippy:: cast_possible_truncation,
98+ reason = "this value will always be less than one billion"
99+ ) ]
94100 nanos : ( data. source_timestamp_us . 0 % 1_000_000 * 1000 ) as i32 ,
95101 special_fields : Default :: default ( ) ,
96102 } ) ;
@@ -133,9 +139,15 @@ async fn try_handle_publisher(
133139 ) {
134140 Ok ( ( data, _) ) => {
135141 let source_timestamp = MessageField :: some ( Timestamp {
136- #[ allow( clippy:: cast_possible_wrap, reason = "Unix seconds won't wrap any time soon" ) ]
142+ #[ allow(
143+ clippy:: cast_possible_wrap,
144+ reason = "Unix seconds won't wrap any time soon"
145+ ) ]
137146 seconds : ( data. source_timestamp_us . 0 / 1_000_000 ) as i64 ,
138- #[ allow( clippy:: cast_possible_truncation, reason = "this value will always be less than one billion" ) ]
147+ #[ allow(
148+ clippy:: cast_possible_truncation,
149+ reason = "this value will always be less than one billion"
150+ ) ]
139151 nanos : ( data. source_timestamp_us . 0 % 1_000_000 * 1000 ) as i32 ,
140152 special_fields : Default :: default ( ) ,
141153 } ) ;
0 commit comments