Function with_active_namespaces

src/main.rs:134–141

(
    active_namespaces: Arc<Mutex<HashMap<String, tokio::task::JoinHandle<()>>>>,
)

}

fn with_active_namespaces(
    active_namespaces: Arc<Mutex<HashMap<String, tokio::task::JoinHandle<()>>>>,
) -> impl Filter<
    Extract = (Arc<Mutex<HashMap<String, tokio::task::JoinHandle<()>>>>,),
    Error = std::convert::Infallible,
> + Clone {
    warp::any().map(move || active_namespaces.clone())
}

async fn ensure_namespace_initialized(
    namespace_id: &String,