Function blocking_complete

crates/openshell-cli/src/completers.rs:138–153

Run an async future on a dedicated thread to avoid nested tokio runtime panics. `#[tokio::main]` creates a runtime, and `CompleteEnv::complete()` runs synchronously inside its `block_on`. Creating another runtime on the same thread would panic, so we spawn a new OS thread with its own single-threaded runtime.

(future: F)

/// inside its `block_on`. Creating another runtime on the same thread would panic, so
/// we spawn a new OS thread with its own single-threaded runtime.
fn blocking_complete<F>(future: F) -> Vec<CompletionCandidate>
where
    F: Future<Output = Option<Vec<CompletionCandidate>>> + Send + 'static,
{
    std::thread::spawn(move || {
        let rt = tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .ok()?;
        rt.block_on(future)
    })
    .join()
    .ok()
    .flatten()
    .unwrap_or_default()
}

#[cfg(test)]
mod tests {