@@ -291,7 +291,7 @@ pub(crate) async fn handle_unilateral(
291
291
292
292
match res. parsed ( ) {
293
293
Response :: MailboxData ( MailboxDatum :: Status { mailbox, status } ) => {
294
- let _ = unsolicited
294
+ unsolicited
295
295
. send ( UnsolicitedResponse :: Status {
296
296
mailbox : ( * mailbox) . into ( ) ,
297
297
attributes : status
@@ -307,23 +307,32 @@ pub(crate) async fn handle_unilateral(
307
307
} )
308
308
. collect ( ) ,
309
309
} )
310
- . await ; //TODO: decide what to do with result
310
+ . await
311
+ . expect ( "Channel closed unexpectedly" ) ;
311
312
}
312
313
Response :: MailboxData ( MailboxDatum :: Recent ( n) ) => {
313
- //TODO: decide what to do with result
314
- let _ = unsolicited. send ( UnsolicitedResponse :: Recent ( * n) ) . await ;
314
+ unsolicited
315
+ . send ( UnsolicitedResponse :: Recent ( * n) )
316
+ . await
317
+ . expect ( "Channel closed unexpectedly" ) ;
315
318
}
316
319
Response :: MailboxData ( MailboxDatum :: Exists ( n) ) => {
317
- //TODO: decide what to do with result
318
- let _ = unsolicited. send ( UnsolicitedResponse :: Exists ( * n) ) . await ;
320
+ unsolicited
321
+ . send ( UnsolicitedResponse :: Exists ( * n) )
322
+ . await
323
+ . expect ( "Channel closed unexpectedly" ) ;
319
324
}
320
325
Response :: Expunge ( n) => {
321
- //TODO: decide what to do with result
322
- let _ = unsolicited. send ( UnsolicitedResponse :: Expunge ( * n) ) . await ;
326
+ unsolicited
327
+ . send ( UnsolicitedResponse :: Expunge ( * n) )
328
+ . await
329
+ . expect ( "Channel closed unexpectedly" ) ;
323
330
}
324
331
_ => {
325
- //TODO: decide what to do with result
326
- let _ = unsolicited. send ( UnsolicitedResponse :: Other ( res) ) . await ;
332
+ unsolicited
333
+ . send ( UnsolicitedResponse :: Other ( res) )
334
+ . await
335
+ . expect ( "Channel closed unexpectedly" ) ;
327
336
}
328
337
}
329
338
}
0 commit comments