fixes

Urigo · Sep 13, 2017 · 05d1e67 · 05d1e67
1 parent 6b8fead
commit 05d1e67
Show file tree

Hide file tree

Showing 8 changed files with 14 additions and 11 deletions.
diff --git a/dist/ObservableCollection.d.ts b/dist/ObservableCollection.d.ts
@@ -1,3 +1,4 @@
+import { Mongo } from 'meteor/mongo';
 import { Observable } from 'rxjs';
 import { ObservableCursor } from './ObservableCursor';
 import Selector = Mongo.Selector;

diff --git a/dist/ObservableCollection.js b/dist/ObservableCollection.js
diff --git a/dist/ObservableCollection.js.map b/dist/ObservableCollection.js.map
diff --git a/dist/ObservableCursor.js b/dist/ObservableCursor.js
diff --git a/dist/ObservableCursor.js.map b/dist/ObservableCursor.js.map
diff --git a/dist/bundles/index.umd.js b/dist/bundles/index.umd.js
@@ -1,8 +1,8 @@
 (function (global, factory) {
-	typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('rxjs')) :
-	typeof define === 'function' && define.amd ? define(['exports', 'rxjs'], factory) :
-	(factory((global.meteor = global.meteor || {}, global.meteor.rxjs = {}),global.rxjs));
-}(this, (function (exports,rxjs) { 'use strict';
+	typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('meteor/mongo'), require('rxjs')) :
+	typeof define === 'function' && define.amd ? define(['exports', 'meteor/mongo', 'rxjs'], factory) :
+	(factory((global.meteor = global.meteor || {}, global.meteor.rxjs = {}),global.mongo,global.rxjs));
+}(this, (function (exports,mongo,rxjs) { 'use strict';
 
 'use strict';
 var subscribeEvents = ['onReady', 'onError', 'onStop'];
@@ -80,7 +80,7 @@ var ObservableCursor = /** @class */ (function (_super) {
             if (!_this._hCursor) {
                 _this._hCursor = _this._observeCursor(cursor);
             }
-            setTimeout(function () {
+            Meteor.setTimeout(function () {
                 if (_this._isDataInitinialized) {
                     observer.next(_this._data);
                 }
@@ -261,11 +261,11 @@ var ObservableCursor = /** @class */ (function (_super) {
          *  @constructor
          */
         function Collection(nameOrExisting, options) {
-            if (nameOrExisting instanceof Mongo.Collection) {
+            if (nameOrExisting instanceof mongo.Mongo.Collection) {
                 this._collection = nameOrExisting;
             }
             else {
-                this._collection = new Mongo.Collection(nameOrExisting, options);
+                this._collection = new mongo.Mongo.Collection(nameOrExisting, options);
             }
         }
         Object.defineProperty(Collection.prototype, "collection", {

diff --git a/src/ObservableCollection.ts b/src/ObservableCollection.ts
@@ -1,3 +1,4 @@
+import { Mongo } from 'meteor/mongo';
 import { Observable, Subscriber } from 'rxjs';
 import { ObservableCursor } from './ObservableCursor';
 import { removeObserver } from './utils';

diff --git a/src/ObservableCursor.ts b/src/ObservableCursor.ts
@@ -40,7 +40,7 @@ export class ObservableCursor<T> extends Observable<T[]> {
         this._hCursor = this._observeCursor(cursor);
       }
 
-      setTimeout(() => {
+      Meteor.setTimeout(() => {
         if (this._isDataInitinialized) {
           observer.next(this._data);
         } else if (cursor.count() === 0) {