watcher_callback

projectatlas::runtime::source_observation

Function watcher_callback 

Source 
fn watcher_callback(
    sender: SyncSender<Event>,
    ingress_sequence: Arc<AtomicU64>,
    continuity_lost: Arc<AtomicBool>,
) -> impl FnMut(Result<Event>) + Send + 'static
Expand description

Convert native watcher callbacks into bounded ingress and continuity state.