From 297b5adbcc1d05d396fa06f45217407eff36eb8e Mon Sep 17 00:00:00 2001
From: okland <omri.klinger@gmail.com>
Date: Mon, 28 Mar 2016 16:10:41 +0300
Subject: [PATCH] Update polling_observe_driver.js

Added support for bulkEnded
---
 packages/mongo/polling_observe_driver.js | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/packages/mongo/polling_observe_driver.js b/packages/mongo/polling_observe_driver.js
index c50160b7bfc..3418395ef3a 100644
--- a/packages/mongo/polling_observe_driver.js
+++ b/packages/mongo/polling_observe_driver.js
@@ -176,7 +176,10 @@ _.extend(PollingObserveDriver.prototype, {
       LocalCollection._diffQueryChanges(
         self._ordered, oldResults, newResults, self._multiplexer);
     }
-
+    
+    // Notify that bulkEnded
+    self._multiplexer.bulkEnded && self._multiplexer.bulkEnded();
+    
     // Signals the multiplexer to allow all observeChanges calls that share this
     // multiplexer to return. (This happens asynchronously, via the
     // multiplexer's queue.)