diff --git a/packages/minimongo/minimongo.js b/packages/minimongo/minimongo.js
index 1ad78cef14..841f0118ce 100644
--- a/packages/minimongo/minimongo.js
+++ b/packages/minimongo/minimongo.js
@@ -207,7 +207,7 @@ LocalCollection.LiveResultsSet = function () {};
 _.extend(LocalCollection.Cursor.prototype, {
   observe: function (options) {
     var self = this;
-    return  LocalCollection._observe(self, options);
+    return  LocalCollection._observeFromObserveChanges(self, options);
   },
   observeChanges: function (options) {
     var self = this;
@@ -787,15 +787,16 @@ LocalCollection._makeChangedFields = function (newDoc, oldDoc) {
   return fields;
 };
 
-LocalCollection._observe = function (cursor, callbacks) {
+LocalCollection._observeFromObserveChanges = function (cursor, callbacks) {
   if (callbacks.addedAt || callbacks.movedTo ||
       callbacks.changedAt || callbacks.removedAt)
-    return LocalCollection._observeOrdered(cursor, callbacks);
+    return LocalCollection._observeOrderedFromObserveChanges(cursor, callbacks);
   else
-    return LocalCollection._observeUnordered(cursor, callbacks);
+    return LocalCollection._observeUnorderedFromObserveChanges(cursor, callbacks);
 };
 
-LocalCollection._observeUnordered = function (cursor, callbacks) {
+LocalCollection._observeUnorderedFromObserveChanges =
+    function (cursor, callbacks) {
   var docs = {};
   var suppressed = !!callbacks._suppress_initial;
   var handle = cursor.observeChanges({
@@ -825,7 +826,8 @@ LocalCollection._observeUnordered = function (cursor, callbacks) {
   return handle;
 };
 
-LocalCollection._observeOrdered = function (cursor, callbacks) {
+LocalCollection._observeOrderedFromObserveChanges =
+    function (cursor, callbacks) {
   var docs = new OrderedDict();
   var suppressed = !!callbacks._suppress_initial;
   var handle = cursor.observeChanges({
@@ -849,13 +851,11 @@ LocalCollection._observeOrdered = function (cursor, callbacks) {
       var oldDoc = EJSON.clone(doc);
       // writes through to the doc set
       LocalCollection._applyChanges(doc, fields);
-      if (!suppressed) {
-        if (callbacks.changedAt) {
-          var index = docs.indexOf(strId);
-          callbacks.changedAt(EJSON.clone(doc), oldDoc, index);
-        } else if (callbacks.changed) {
-          callbacks.changed(EJSON.clone(doc), oldDoc);
-        }
+      if (callbacks.changedAt) {
+        var index = docs.indexOf(strId);
+        callbacks.changedAt(EJSON.clone(doc), oldDoc, index);
+      } else if (callbacks.changed) {
+        callbacks.changed(EJSON.clone(doc), oldDoc);
       }
     },
     movedBefore: function (id, before) {
@@ -863,29 +863,26 @@ LocalCollection._observeOrdered = function (cursor, callbacks) {
       var doc = docs.get(strId);
       var from;
       // only capture indexes if we're going to call the callback that needs them.
-      if (!suppressed && callbacks.movedTo)
+      if (callbacks.movedTo)
         from = docs.indexOf(strId);
       docs.moveBefore(strId, before ? LocalCollection._idStringify(before) : null);
-      if (!suppressed) {
-        if (callbacks.movedTo) {
-          var to = docs.indexOf(strId);
-          callbacks.movedTo(EJSON.clone(doc), from, to);
-        } else if (callbacks.moved) {
-          callbacks.moved(EJSON.clone(doc));
-        }
+      if (callbacks.movedTo) {
+        var to = docs.indexOf(strId);
+        callbacks.movedTo(EJSON.clone(doc), from, to);
+      } else if (callbacks.moved) {
+        callbacks.moved(EJSON.clone(doc));
       }
+
     },
     removed: function (id) {
       var strId = LocalCollection._idStringify(id);
       var doc = docs.get(strId);
       var index;
-      if (!suppressed && callbacks.removedAt)
+      if (callbacks.removedAt)
         index = docs.indexOf(strId);
       docs.remove(strId);
-      if (!suppressed) {
-        callbacks.removedAt && callbacks.removedAt(doc, index);
-        callbacks.removed && callbacks.removed(doc);
-      }
+      callbacks.removedAt && callbacks.removedAt(doc, index);
+      callbacks.removed && callbacks.removed(doc);
     }
   });
   suppressed = false;
diff --git a/packages/mongo-livedata/collection.js b/packages/mongo-livedata/collection.js
index c80595bfb5..c3b38432ed 100644
--- a/packages/mongo-livedata/collection.js
+++ b/packages/mongo-livedata/collection.js
@@ -105,8 +105,10 @@ Meteor.Collection = function (name, options) {
           }
           return;
         } else if (msg.msg === 'added') {
-          if (doc)
+          if (doc) {
+            debugger;
             throw new Error("Expected not to find a document already present for an add");
+          }
           self._collection.insert(_.extend({_id: mongoId}, msg.fields));
         } else if (msg.msg === 'removed') {
           if (!doc)
diff --git a/packages/mongo-livedata/mongo_driver.js b/packages/mongo-livedata/mongo_driver.js
index 12535f679e..1b1086865a 100644
--- a/packages/mongo-livedata/mongo_driver.js
+++ b/packages/mongo-livedata/mongo_driver.js
@@ -364,7 +364,7 @@ Cursor.prototype._publishCursor = function (sub) {
 
 Cursor.prototype.observe = function (callbacks) {
   var self = this;
-  return LocalCollection._observe(self, callbacks);
+  return LocalCollection._observeFromObserveChanges(self, callbacks);
 };
 
 Cursor.prototype.observeChanges = function (callbacks) {