Function flush_subscribers

View as Markdown

Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.

pub fn flush_subscribers() -> Result<()>

Wait for all subscriber callbacks queued before this call to finish.

Native targets deliver subscriber callbacks on a background dispatcher so event-producing APIs do not wait for observer work. Call this helper from tests, shutdown paths, or exporter lifecycle code when callers need a deterministic observation barrier.