meteor/mongo-livedata/oplog_observe_driver.js
function (id) {
    var self = this;
    if (! self._published.has(id) && ! self._limit)
      throw Error("tried to remove something matching but not cached " + id);

    if (self._published.has(id)) {
      self._removePublished(id);
    } else if (self._unpublishedBuffer.has(id)) {
      self._removeBuffered(id);
    }
  }
function (id) {
    var self = this;
    if (! self._published.has(id) && ! self._limit)
      throw Error("tried to remove something matching but not cached " + id);

    if (self._published.has(id)) {
      self._removePublished(id);
    } else if (self._unpublishedBuffer.has(id)) {
      self._removeBuffered(id);
    }
  }
function ( id ) { var self = this ; if ( ! self . _published . has ( id ) && ! self . _limit ) throw Error ( "tried to remove something matching but not cached " + id ) ; if ( self . _published . has ( id ) ) { self . _removePublished ( id ) ; } else if ( self . _unpublishedBuffer . has ( id ) ) { self . _removeBuffered ( id ) ; } }
Called when a document leaves the "Matching" results set. Takes responsibility of keeping _unpublishedBuffer in sync with _published and the effect of limit enforced.
Called when a document leaves the Matching results set . Takes responsibility of keeping _unpublishedBuffer in sync with _published and the effect of limit enforced .