+ let events = nodes[2].node.get_and_clear_pending_events();
+ if deliver_last_raa {
+ assert_eq!(events.len(), 2);
+ match events[1] {
+ Event::ChannelClosed { .. } => {}
+ _ => panic!("Unexpected event"),
+ }
+ connect_blocks(&nodes[2], ANTI_REORG_DELAY - 1);
+ check_closed_broadcast!(nodes[2], true);
+ expect_pending_htlcs_forwardable!(nodes[2], events[0..1]);
+ } else {
+ assert_eq!(events.len(), 1);
+ match events[0] {
+ Event::ChannelClosed { .. } => {}
+ _ => panic!("Unexpected event"),
+ }
+ connect_blocks(&nodes[2], ANTI_REORG_DELAY - 1);
+ check_closed_broadcast!(nodes[2], true);
+ let events = nodes[2].node.get_and_clear_pending_events();
+ expect_pending_htlcs_forwardable!(nodes[2], events);
+ }