@@ -1406,6 +1406,11 @@ mod tests {
14061406 // The rejected chain is returned. The earlier chain remains in flight.
14071407 assert_eq ! ( producer. poll( ) . unwrap( ) . unwrap( ) . token( ) , rejected) ;
14081408 assert ! ( producer. poll( ) . unwrap( ) . is_none( ) ) ;
1409+
1410+ drop ( consumer) ;
1411+ // SAFETY: The peer is stopped and all consumer chain handles are dropped.
1412+ unsafe { producer. reset ( ) . unwrap ( ) } ;
1413+ assert_eq ! ( producer. pool( ) . num_live( ) , 0 ) ;
14091414 }
14101415
14111416 #[ test]
@@ -1428,6 +1433,11 @@ mod tests {
14281433 assert_eq ! ( consumer. inner. num_inflight( ) , 0 ) ;
14291434 assert_eq ! ( consumer. next_token, 0 ) ;
14301435 assert ! ( producer. poll( ) . unwrap( ) . is_none( ) ) ;
1436+
1437+ drop ( consumer) ;
1438+ // SAFETY: The peer is stopped and all consumer chain handles are dropped.
1439+ unsafe { producer. reset ( ) . unwrap ( ) } ;
1440+ assert_eq ! ( producer. pool( ) . num_live( ) , 0 ) ;
14311441 }
14321442
14331443 #[ test]
@@ -1452,6 +1462,11 @@ mod tests {
14521462 assert_eq ! ( consumer. inner. num_inflight( ) , 1 ) ;
14531463 assert_eq ! ( consumer. next_token, 1 ) ;
14541464 assert ! ( producer. poll( ) . unwrap( ) . is_none( ) ) ;
1465+
1466+ drop ( consumer) ;
1467+ // SAFETY: The peer is stopped and all consumer chain handles are dropped.
1468+ unsafe { producer. reset ( ) . unwrap ( ) } ;
1469+ assert_eq ! ( producer. pool( ) . num_live( ) , 0 ) ;
14551470 }
14561471
14571472 #[ test]
0 commit comments