bugfix(multiple-subscribers): Attempt to fix the multiple subscribers…

… issue
Urigo · Oct 25, 2016 · ace9c78 · ace9c78
1 parent e79af51
commit ace9c78
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/dist/ObservableCollection.js b/dist/ObservableCollection.js
@@ -86,7 +86,7 @@ export var MongoObservable;
         };
         Collection.prototype.find = function (selector, options) {
             var cursor = this._collection.find.apply(this._collection, arguments);
-            return ObservableCursor.create(cursor);
+            return ObservableCursor.create(cursor).publish().refCount();
         };
         Collection.prototype.findOne = function (selector, options) {
             return this._collection.findOne.apply(this._collection, arguments);

diff --git a/dist/bundles/index.umd.js b/dist/bundles/index.umd.js
@@ -242,7 +242,7 @@ var ObservableCursor = (function (_super) {
         };
         Collection.prototype.find = function (selector, options) {
             var cursor = this._collection.find.apply(this._collection, arguments);
-            return ObservableCursor.create(cursor);
+            return ObservableCursor.create(cursor).publish().refCount();
         };
         Collection.prototype.findOne = function (selector, options) {
             return this._collection.findOne.apply(this._collection, arguments);

diff --git a/src/ObservableCollection.ts b/src/ObservableCollection.ts
@@ -142,7 +142,7 @@ export module MongoObservable {
     }): ObservableCursor<T> {
       const cursor = this._collection.find.apply(
         this._collection, arguments);
-      return ObservableCursor.create<T>(cursor);
+      return ObservableCursor.create<T>(cursor).publish().refCount();
     }
 
     findOne(selector?: Selector | ObjectID | string, options?: {