Function shared_tokio_runtime

src/utils/runtime.rs:8–14

()

use tokio::time::sleep;

pub fn shared_tokio_runtime() -> Arc<Runtime> {
    static RUNTIME: OnceLock<Arc<Runtime>> = OnceLock::new();

    RUNTIME
        .get_or_init(|| Arc::new(Runtime::new().expect("Failed to create shared Tokio runtime")))
        .clone()
}

struct DebouncedJsonWriterState<T> {
    pending: Option<T>,