From 9ebaae9ba0feecb221e6c8b9d4db90c42a978926 Mon Sep 17 00:00:00 2001
From: inv2004 <gPoiuhjkl1>
Date: Thu, 20 Dec 2018 00:33:41 -0500
Subject: [PATCH] pipeline is returned in test

---
 tests/change_stream.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 {