pipeline is returned in test

6 years ago · 9ebaae9ba0
parent 5849697bcd
commit 9ebaae9ba0
1 changed files with 2 additions and 1 deletions
--- 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 {