()
| 907 | |
| 908 | #[tokio::test] |
| 909 | async fn test_cancel_nonexistent() { |
| 910 | let (event_tx, _) = broadcast::channel(100); |
| 911 | let manager = ConfirmationManager::new(ConfirmationPolicy::enabled(), event_tx); |
| 912 | |
| 913 | let cancelled = manager.cancel("non-existent").await; |
| 914 | assert!(!cancelled); |
| 915 | } |
| 916 | |
| 917 | #[tokio::test] |
| 918 | async fn test_cancel_all() { |