diff --git a/dist/MeteorObservable.js b/dist/MeteorObservable.js
index 82a42cfb..19e65e26 100644
--- a/dist/MeteorObservable.js
+++ b/dist/MeteorObservable.js
@@ -1,6 +1,7 @@
 'use strict';
 import { Observable } from 'rxjs';
 import { isMeteorCallbacks, forkZone, removeObserver } from './utils';
+var liveSubscriptions = [];
 function throwInvalidCallback(method) {
     throw new Error("Invalid " + method + " arguments:\n     your last param can't be a callback function, \n     please remove it and use \".subscribe\" of the Observable!");
 }
@@ -157,9 +158,23 @@ export var MeteorObservable = (function () {
             // Execute subscribe lazily.
             if (subHandler === null) {
                 subHandler = subscribe();
+                if (liveSubscriptions.find(function (sub) { return sub === subHandler.subscriptionId; })) {
+                    // subscription already exists, call observer.next() since Meteor won't.
+                    observer.next();
+                }
+                else {
+                    liveSubscriptions.push(subHandler.subscriptionId);
+                }
             }
             return function () {
-                removeObserver(observers, observer, function () { return subHandler.stop(); });
+                removeObserver(observers, observer, function () {
+                    // remove subscription from liveSubscriptions list
+                    var i = liveSubscriptions.findIndex(function (sub) { return sub === subHandler.subscriptionId; });
+                    if (i > -1) {
+                        liveSubscriptions.splice(i, 1);
+                    }
+                    subHandler.stop();
+                });
             };
         });
     };
diff --git a/dist/MeteorObservable.js.map b/dist/MeteorObservable.js.map
index 40bdd642..81b7ed93 100644
--- a/dist/MeteorObservable.js.map
+++ b/dist/MeteorObservable.js.map
@@ -1 +1 @@
-{"version":3,"file":"MeteorObservable.js","sourceRoot":"","sources":["../src/MeteorObservable.ts"],"names":[],"mappings":"AAAA,YAAY,CAAC;OAEN,EAAC,UAAU,EAAa,MAAM,MAAM;OACpC,EAAC,iBAAiB,EAAE,QAAQ,EAAE,cAAc,EAAC,MAAM,SAAS;AAEnE,8BAA8B,MAAc;IAC1C,MAAM,IAAI,KAAK,CACb,aAAW,MAAM,sIAEyC,CAAC,CAAC;AAChE,CAAC;AAED;;;;;;;;;GASG;AACH;IAAA;IAmMA,CAAC;IAjMC;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA6BG;IACW,qBAAI,GAAlB,UAAsB,IAAY;QAAE,cAAc;aAAd,WAAc,CAAd,sBAAc,CAAd,IAAc;YAAd,6BAAc;;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC;QAExC,EAAE,CAAC,CAAC,iBAAiB,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC;YACjC,oBAAoB,CAAC,uBAAuB,CAAC,CAAC;QAChD,CAAC;QAED,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QAEtB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAsC;YAC9D,MAAM,CAAC,IAAI,OAAX,MAAM,GAAM,IAAI,SAAK,IAAI,CAAC,MAAM,CAAC;gBAC/B,UAAC,KAAmB,EAAE,MAAS;oBAC7B,IAAI,CAAC,GAAG,CAAC;wBACP,KAAK,GAAG,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC;4BAC3B,QAAQ,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;wBACxB,QAAQ,CAAC,QAAQ,EAAE,CAAC;oBACtB,CAAC,CAAC,CAAC;gBACL,CAAC;aACF,CAAC,EAAC,CAAC;QACN,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OAuDG;IACW,0BAAS,GAAvB,UAA2B,IAAY;QAAE,cAAc;aAAd,WAAc,CAAd,sBAAc,CAAd,IAAc;YAAd,6BAAc;;QACrD,IAAI,SAAS,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC;QAEtC,EAAE,CAAC,CAAC,iBAAiB,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC;YACjC,oBAAoB,CAAC,4BAA4B,CAAC,CAAC;QACrD,CAAC;QAED,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QACtB,IAAI,SAAS,GAAG,EAAE,CAAC;QACnB,IAAI,SAAS,GAAG;YACd,MAAM,CAAC,MAAM,CAAC,SAAS,OAAhB,MAAM,GAAW,IAAI,SAAK,IAAI,CAAC,MAAM,CAAC,CAAC;oBAC1C,OAAO,EAAE,UAAC,KAAmB;wBAC3B,IAAI,CAAC,GAAG,CAAC;4BACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAArB,CAAqB,CAAC,CAAC;wBACvD,CAAC,CAAC,CAAC;oBACL,CAAC;oBACD,OAAO,EAAE;wBACP,IAAI,CAAC,GAAG,CAAC;4BACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,IAAI,EAAE,EAAf,CAAe,CAAC,CAAC;wBACjD,CAAC,CAAC,CAAC;oBACL,CAAC;iBACF;aACF,CAAC,EAAC,CAAC;QACN,CAAC,CAAC;QAEF,IAAI,UAAU,GAAG,IAAI,CAAC;QACtB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAsC;YAC9D,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACzB,4BAA4B;YAC5B,EAAE,CAAC,CAAC,UAAU,KAAK,IAAI,CAAC,CAAC,CAAC;gBACxB,UAAU,GAAG,SAAS,EAAE,CAAC;YAC3B,CAAC;YACD,MAAM,CAAC;gBACL,cAAc,CAAC,SAAS,EACtB,QAAQ,EAAE,cAAM,OAAA,UAAU,CAAC,IAAI,EAAE,EAAjB,CAAiB,CAAC,CAAC;YACvC,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;OAqBG;IACW,wBAAO,GAArB;QACE,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QACtB,IAAI,SAAS,GAAG,EAAE,CAAC;QACnB,IAAI,OAAO,GAAG;YACZ,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,UAAC,WAAgC;gBACtD,IAAI,CAAC,GAAG,CAAC;oBACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,IAAI,CAAC,WAAW,CAAC,EAA1B,CAA0B,CAAC,CAAC;gBAC5D,CAAC,CAAC,CAAC;YACL,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QAEF,IAAI,OAAO,GAAG,IAAI,CAAC;QACnB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAwD;YAChF,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACzB,0BAA0B;YAC1B,EAAE,CAAC,CAAC,OAAO,KAAK,IAAI,CAAC,CAAC,CAAC;gBACrB,OAAO,GAAG,OAAO,EAAE,CAAC;YACtB,CAAC;YACD,MAAM,CAAC;gBACL,cAAc,CAAC,SAAS,EACtB,QAAQ,EAAE,cAAM,OAAA,OAAO,CAAC,IAAI,EAAE,EAAd,CAAc,CAAC,CAAC;YACpC,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC;IACH,uBAAC;AAAD,CAAC,AAnMD,IAmMC"}
\ No newline at end of file
+{"version":3,"file":"MeteorObservable.js","sourceRoot":"","sources":["../src/MeteorObservable.ts"],"names":[],"mappings":"AAAA,YAAY,CAAC;OAEN,EAAC,UAAU,EAAa,MAAM,MAAM;OACpC,EAAC,iBAAiB,EAAE,QAAQ,EAAE,cAAc,EAAC,MAAM,SAAS;AAEnE,IAAI,iBAAiB,GAAG,EAAE,CAAC;AAE3B,8BAA8B,MAAc;IAC1C,MAAM,IAAI,KAAK,CACb,aAAW,MAAM,sIAEyC,CAAC,CAAC;AAChE,CAAC;AAED;;;;;;;;;GASG;AACH;IAAA;IAqNA,CAAC;IAnNC;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OA6BG;IACW,qBAAI,GAAlB,UAAsB,IAAY;QAAE,cAAc;aAAd,WAAc,CAAd,sBAAc,CAAd,IAAc;YAAd,6BAAc;;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC;QAExC,EAAE,CAAC,CAAC,iBAAiB,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC;YACjC,oBAAoB,CAAC,uBAAuB,CAAC,CAAC;QAChD,CAAC;QAED,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QAEtB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAsC;YAC9D,MAAM,CAAC,IAAI,OAAX,MAAM,GAAM,IAAI,SAAK,IAAI,CAAC,MAAM,CAAC;gBAC/B,UAAC,KAAmB,EAAE,MAAS;oBAC7B,IAAI,CAAC,GAAG,CAAC;wBACP,KAAK,GAAG,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC;4BAC3B,QAAQ,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;wBACxB,QAAQ,CAAC,QAAQ,EAAE,CAAC;oBACtB,CAAC,CAAC,CAAC;gBACL,CAAC;aACF,CAAC,EAAC,CAAC;QACN,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;OAuDG;IACW,0BAAS,GAAvB,UAA2B,IAAY;QAAE,cAAc;aAAd,WAAc,CAAd,sBAAc,CAAd,IAAc;YAAd,6BAAc;;QACrD,IAAI,SAAS,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC;QAEtC,EAAE,CAAC,CAAC,iBAAiB,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC;YACjC,oBAAoB,CAAC,4BAA4B,CAAC,CAAC;QACrD,CAAC;QAED,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QACtB,IAAI,SAAS,GAAG,EAAE,CAAC;QACnB,IAAI,SAAS,GAAG;YACd,MAAM,CAAC,MAAM,CAAC,SAAS,OAAhB,MAAM,GAAW,IAAI,SAAK,IAAI,CAAC,MAAM,CAAC,CAAC;oBAC1C,OAAO,EAAE,UAAC,KAAmB;wBAC3B,IAAI,CAAC,GAAG,CAAC;4BACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAArB,CAAqB,CAAC,CAAC;wBACvD,CAAC,CAAC,CAAC;oBACL,CAAC;oBACD,OAAO,EAAE;wBACP,IAAI,CAAC,GAAG,CAAC;4BACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,IAAI,EAAE,EAAf,CAAe,CAAC,CAAC;wBACjD,CAAC,CAAC,CAAC;oBACL,CAAC;iBACF;aACF,CAAC,EAAC,CAAC;QACN,CAAC,CAAC;QAEF,IAAI,UAAU,GAAG,IAAI,CAAC;QACtB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAsC;YAC9D,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACzB,4BAA4B;YAC5B,EAAE,CAAC,CAAC,UAAU,KAAK,IAAI,CAAC,CAAC,CAAC;gBACxB,UAAU,GAAG,SAAS,EAAE,CAAC;gBACzB,EAAE,CAAC,CAAC,iBAAiB,CAAC,IAAI,CAAC,UAAA,GAAG,IAAI,OAAA,GAAG,KAAK,UAAU,CAAC,cAAc,EAAjC,CAAiC,CAAC,CAAC,CAAC,CAAC;oBACrE,wEAAwE;oBACxE,QAAQ,CAAC,IAAI,EAAE,CAAC;gBAClB,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,iBAAiB,CAAC,IAAI,CAAC,UAAU,CAAC,cAAc,CAAC,CAAC;gBACpD,CAAC;YACH,CAAC;YACD,MAAM,CAAC;gBACL,cAAc,CAAC,SAAS,EACtB,QAAQ,EAAE;oBACR,kDAAkD;oBAClD,IAAI,CAAC,GAAG,iBAAiB,CAAC,SAAS,CACjC,UAAA,GAAG,IAAI,OAAA,GAAG,KAAK,UAAU,CAAC,cAAc,EAAjC,CAAiC,CACzC,CAAC;oBAEF,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC;wBACX,iBAAiB,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;oBACjC,CAAC;oBAED,UAAU,CAAC,IAAI,EAAE,CAAC;gBAEpB,CAAC,CAAC,CAAC;YACP,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;;;;;;;;;;;;;;;;OAqBG;IACW,wBAAO,GAArB;QACE,IAAI,IAAI,GAAG,QAAQ,EAAE,CAAC;QACtB,IAAI,SAAS,GAAG,EAAE,CAAC;QACnB,IAAI,OAAO,GAAG;YACZ,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,UAAC,WAAgC;gBACtD,IAAI,CAAC,GAAG,CAAC;oBACP,SAAS,CAAC,OAAO,CAAC,UAAA,QAAQ,IAAI,OAAA,QAAQ,CAAC,IAAI,CAAC,WAAW,CAAC,EAA1B,CAA0B,CAAC,CAAC;gBAC5D,CAAC,CAAC,CAAC;YACL,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QAEF,IAAI,OAAO,GAAG,IAAI,CAAC;QACnB,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,UAAC,QAAwD;YAChF,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACzB,0BAA0B;YAC1B,EAAE,CAAC,CAAC,OAAO,KAAK,IAAI,CAAC,CAAC,CAAC;gBACrB,OAAO,GAAG,OAAO,EAAE,CAAC;YACtB,CAAC;YACD,MAAM,CAAC;gBACL,cAAc,CAAC,SAAS,EACtB,QAAQ,EAAE,cAAM,OAAA,OAAO,CAAC,IAAI,EAAE,EAAd,CAAc,CAAC,CAAC;YACpC,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC;IACH,uBAAC;AAAD,CAAC,AArND,IAqNC"}
\ No newline at end of file
diff --git a/dist/bundles/index.umd.js b/dist/bundles/index.umd.js
index c4928c6a..4c308229 100644
--- a/dist/bundles/index.umd.js
+++ b/dist/bundles/index.umd.js
@@ -470,6 +470,7 @@ var ObservableCursor = (function (_super) {
  * @property {Boolean} upsert - True to use upsert logic.
  */
 
+var liveSubscriptions = [];
 function throwInvalidCallback(method) {
     throw new Error("Invalid " + method + " arguments:\n     your last param can't be a callback function, \n     please remove it and use \".subscribe\" of the Observable!");
 }
@@ -626,9 +627,23 @@ var MeteorObservable = (function () {
             // Execute subscribe lazily.
             if (subHandler === null) {
                 subHandler = subscribe();
+                if (liveSubscriptions.find(function (sub) { return sub === subHandler.subscriptionId; })) {
+                    // subscription already exists, call observer.next() since Meteor won't.
+                    observer.next();
+                }
+                else {
+                    liveSubscriptions.push(subHandler.subscriptionId);
+                }
             }
             return function () {
-                removeObserver(observers, observer, function () { return subHandler.stop(); });
+                removeObserver(observers, observer, function () {
+                    // remove subscription from liveSubscriptions list
+                    var i = liveSubscriptions.findIndex(function (sub) { return sub === subHandler.subscriptionId; });
+                    if (i > -1) {
+                        liveSubscriptions.splice(i, 1);
+                    }
+                    subHandler.stop();
+                });
             };
         });
     };
diff --git a/src/MeteorObservable.ts b/src/MeteorObservable.ts
index 8e05161e..4916f91d 100644
--- a/src/MeteorObservable.ts
+++ b/src/MeteorObservable.ts
@@ -3,6 +3,8 @@
 import {Observable, Subscriber} from 'rxjs';
 import {isMeteorCallbacks, forkZone, removeObserver} from './utils';
 
+let liveSubscriptions = [];
+
 function throwInvalidCallback(method: string) {
   throw new Error(
     `Invalid ${method} arguments:
@@ -161,10 +163,28 @@ export class MeteorObservable {
       // Execute subscribe lazily.
       if (subHandler === null) {
         subHandler = subscribe();
+        if (liveSubscriptions.find(sub => sub === subHandler.subscriptionId)) {
+          // subscription already exists, call observer.next() since Meteor won't.
+          observer.next();
+        } else {
+          liveSubscriptions.push(subHandler.subscriptionId);
+        }
       }
       return () => {
         removeObserver(observers,
-          observer, () => subHandler.stop());
+          observer, () => {
+            // remove subscription from liveSubscriptions list
+            let i = liveSubscriptions.findIndex(
+              sub => sub === subHandler.subscriptionId
+            );
+
+            if (i > -1) {
+              liveSubscriptions.splice(i, 1);
+            }
+
+            subHandler.stop();
+
+          });
       };
     });
   }