@@ -88,9 +88,15 @@ async fn try_handle_publisher(
88
88
) {
89
89
Ok ( ( data, _) ) => {
90
90
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
+ ) ]
92
95
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
+ ) ]
94
100
nanos : ( data. source_timestamp_us . 0 % 1_000_000 * 1000 ) as i32 ,
95
101
special_fields : Default :: default ( ) ,
96
102
} ) ;
@@ -133,9 +139,15 @@ async fn try_handle_publisher(
133
139
) {
134
140
Ok ( ( data, _) ) => {
135
141
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
+ ) ]
137
146
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
+ ) ]
139
151
nanos : ( data. source_timestamp_us . 0 % 1_000_000 * 1000 ) as i32 ,
140
152
special_fields : Default :: default ( ) ,
141
153
} ) ;
0 commit comments