eventsourcingdb 2.0.4

A client library for the EventsourcingDB by the native web.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

mod utils;
use futures::stream::TryStreamExt;
use utils::create_test_container;

#[tokio::test]
async fn run_empty_query() {
    let container = create_test_container().await;
    let client = container.get_client().await.unwrap();
    let rows = client
        .run_eventql_query("FROM e IN events ORDER BY e.time DESC TOP 100 PROJECT INTO e")
        .await
        .expect("Unable to run query");
    let rows: Result<Vec<_>, _> = rows.try_collect().await;
    assert!(rows.is_ok(), "Failed to run query: {rows:?}");
    let rows = rows.expect("Failed to read rows");
    assert_eq!(rows.len(), 0);
}