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

#[tokio::test]
async fn expr_query() -> unreql::Result<()> {
    let conn = r.connect(()).await?;
    let mut query = r.expr(r.expr("hello")).run(&conn);
    let val: Option<Value> = query.try_next().await?;
    assert_eq!(val, Some(Value::String("hello".into())));
    Ok(())
}