use futures::TryStreamExt;
use reql::r;
use serde_json::Value;

#[tokio::test]
async fn table() -> reql::Result<()> {
    tracing_subscriber::fmt::init();
    let conn = r.connect(()).await?;
    let mut query = r.db("rethinkdb").table("users").run(&conn);
    let user: Option<Value> = query.try_next().await?;
    assert!(user.is_some());
    Ok(())
}