diff --git a/tests/change_stream.rs b/tests/change_stream.rs index ed30d9d..5e4df85 100644 --- a/tests/change_stream.rs +++ b/tests/change_stream.rs @@ -17,7 +17,8 @@ fn test_change_stream() { let guard = thread::spawn(move || { let client = cloned_pool.pop(); let collection = client.get_collection("rust_driver_test", "change_stream"); - let stream = collection.watch(&doc!{}, &doc!{}, Some(1000)).unwrap(); + let pipeline = doc!{"0":{"$match": {"fullDocument.c": {"$gte": 10}}}}; + let stream = collection.watch(&pipeline, &doc!{}, Some(1000)).unwrap(); let mut counter = 10; for x in stream {