vv-agent 0.6.2

VectorVein agent runtime, SDK, CLI, tools, and workspace backends
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::future::Future;
use std::io::Error;

use tokio::runtime::{Builder as RuntimeBuilder, Runtime};

pub(super) fn build_runtime() -> std::io::Result<Runtime> {
    RuntimeBuilder::new_current_thread()
        .enable_all()
        .build()
        .map_err(|error| Error::other(error.to_string()))
}

pub(super) fn block_on_object_store<T>(
    runtime: &Runtime,
    future: impl Future<Output = object_store::Result<T>>,
) -> std::io::Result<T> {
    runtime
        .block_on(future)
        .map_err(crate::workspace::object_store_error_to_io)
}