multithread/
multithread.rs

1use gremlin_client::{GremlinClient, Vertex};
2use std::thread;
3
4fn main() -> Result<(), Box<dyn std::error::Error>> {
5    let client = GremlinClient::connect("localhost")?;
6
7    let c = client.clone();
8
9    let result = thread::spawn(move || {
10        c.execute("g.V(param)", &[("param", &1)])?
11            .filter_map(Result::ok)
12            .map(|f| f.take::<Vertex>())
13            .collect::<Result<Vec<Vertex>, _>>()
14    });
15
16    println!("{:?}", result.join());
17
18    Ok(())
19}