orientdb-client 0.6.0

A Rust client for OrientDB™
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use async_std::task::{self, block_on};
use futures::StreamExt;
use orientdb_client::aio::OrientDB;
use orientdb_client::OrientResult;

fn main() -> OrientResult<()> {
    block_on(async {
        let client = OrientDB::connect(("localhost", 2424)).await?;
        let session = client.session("demodb", "admin", "admin").await?;

        let (unsubscriber, mut stream) = session.live_query("select from V").run().await?;

        task::spawn(async move {
            let _ = session
                .command("insert into V set id = 1")
                .run()
                .await
                .expect("Failed to run the query");
            unsubscriber
                .unsubscribe()
                .await
                .expect("Failed to unsbubscrbe the live query");
        });

        while let Some(item) = stream.next().await {
            println!("Event {:?}", item?);
        }

        Ok(())
    })
}