vv-agent 0.4.6

VectorVein agent runtime, SDK, CLI, tools, and workspace backends
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use std::sync::atomic::{AtomicUsize, Ordering};
use std::sync::Arc;

use serde_json::json;

use super::listeners::{notify_background_listeners, BackgroundSessionListener};

#[test]
fn notify_background_listeners_continues_after_listener_panic() {
    let delivered = Arc::new(AtomicUsize::new(0));
    let delivered_listener = Arc::clone(&delivered);
    let listeners: Vec<BackgroundSessionListener> = vec![
        Arc::new(|_| panic!("boom")),
        Arc::new(move |_| {
            delivered_listener.fetch_add(1, Ordering::Relaxed);
        }),
    ];

    let result = std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
        notify_background_listeners(listeners, &json!({"status": "completed"}));
    }));

    assert!(result.is_ok());
    assert_eq!(delivered.load(Ordering::Relaxed), 1);
}