You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
21 lines
576 B
Rust
21 lines
576 B
Rust
//use bson;
|
|
|
|
use std::sync::Arc;
|
|
use std::thread;
|
|
|
|
use mongo_driver::client::{ClientPool,Uri};
|
|
use mongo_driver::Result;
|
|
|
|
#[test]
|
|
fn test_change_stream() {
|
|
let uri = Uri::new("mongodb://localhost:27017/").unwrap();
|
|
let pool = Arc::new(ClientPool::new(uri, None));
|
|
let client = pool.pop();
|
|
let mut collection = client.get_collection("rust_driver_test", "change_stream");
|
|
|
|
let stream = collection.watch(&doc!{}, &doc!{"maxAwaitTimeMS": 10_000}).unwrap();
|
|
let next = stream.into_iter().next().unwrap().unwrap();
|
|
assert_eq!(true, false);
|
|
}
|
|
|