mod utils;
use qldb::QldbClient;
use std::sync::Arc;
use utils::cursor_utils::cursor_800_documents_with_client;
#[async_std::test]
async fn cursor_800_documents_10_times_parallel_async_std() {
let client = QldbClient::default_with_spawner(
"rust-crate-test",
200,
Arc::new(move |fut| {
async_std::task::spawn(Box::pin(fut));
}),
)
.await
.unwrap();
let tasks = [
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
cursor_800_documents_with_client(client.clone()),
];
futures::future::join_all(tasks).await;
}