diff --git a/lib/subscription.js b/lib/subscription.js index 4e0b77c..bfe76e1 100644 --- a/lib/subscription.js +++ b/lib/subscription.js @@ -23,7 +23,8 @@ class Subscription { added (collectionName, doc) { this.refCounter.increment(collectionName, doc._id) - if (this._hasDocChanged(collectionName, doc._id, doc)) { + const existingDoc = this.docHash[buildHashKey(collectionName, doc.id)] + if (!existingDoc) { debugLog('Subscription.added', `${collectionName}:${doc._id}`) this.meteorSub.added(collectionName, doc._id, doc) this._addDocHash(collectionName, doc)