File tree Expand file tree Collapse file tree 1 file changed +4
-6
lines changed Expand file tree Collapse file tree 1 file changed +4
-6
lines changed Original file line number Diff line number Diff line change @@ -301,25 +301,23 @@ async fn listener(
301
301
PayloadType :: Json => message
302
302
. value
303
303
. as_str( )
304
- . and_then( |s| serde_json:: from_str:: <EventV1 >( s. as_ref( ) ) . ok( ) ) ,
304
+ . and_then( |s| report_internal_error! ( serde_json:: from_str:: <EventV1 >( s. as_ref( ) ) ) . ok( ) ) ,
305
305
PayloadType :: Msgpack => message
306
306
. value
307
307
. as_bytes( )
308
- . and_then( |b| rmp_serde:: from_slice:: <EventV1 >( b) . ok( ) ) ,
308
+ . and_then( |b| report_internal_error! ( rmp_serde:: from_slice:: <EventV1 >( b) ) . ok( ) ) ,
309
309
PayloadType :: Bincode => message
310
310
. value
311
311
. as_bytes( )
312
- . and_then( |b| bincode:: deserialize:: <EventV1 >( b) . ok( ) ) ,
312
+ . and_then( |b| report_internal_error! ( bincode:: deserialize:: <EventV1 >( b) ) . ok( ) ) ,
313
313
} ;
314
314
315
315
let Some ( mut event) = event else {
316
316
let err = format!(
317
- "Failed to deserialise an event for {}! Introspection : `{:?}`" ,
317
+ "Failed to deserialise event for {}: `{:?}`" ,
318
318
message. channel,
319
319
message
320
320
. value
321
- . as_string( )
322
- . map( |x| x. chars( ) . take( 32 ) . collect:: <String >( ) )
323
321
) ;
324
322
325
323
error!( "{}" , err) ;
You can’t perform that action at this time.
0 commit comments