()
| 163 | } |
| 164 | |
| 165 | pub async fn get_ack_events() -> Vec<integration::AckEvent> { |
| 166 | ACK_EVENTS.write().await.drain(..).collect() |
| 167 | } |
| 168 | |
| 169 | pub async fn get_txack_events() -> Vec<integration::TxAckEvent> { |
| 170 | TXACK_EVENTS.write().await.drain(..).collect() |