From 571ba01f16cb554e04bd54c538b591ad374e34b9 Mon Sep 17 00:00:00 2001 From: Slava Kim Date: Fri, 28 Feb 2014 14:25:33 -0800 Subject: [PATCH] Use new sorter + projection api in oplog code --- packages/mongo-livedata/oplog_observe_driver.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/mongo-livedata/oplog_observe_driver.js b/packages/mongo-livedata/oplog_observe_driver.js index 7834a4cbb8..3a12d5a5e1 100644 --- a/packages/mongo-livedata/oplog_observe_driver.js +++ b/packages/mongo-livedata/oplog_observe_driver.js @@ -39,6 +39,8 @@ OplogObserveDriver = function (options) { } var sortSpec = options.cursorDescription.options.sort; + var sorter = sortSpec && new Minimongo.Sorter(sortSpec); + var comparator = sorter && sorter.getComparator(); if (options.cursorDescription.options.limit) { // There are several properties ordered driver implements: @@ -52,8 +54,6 @@ OplogObserveDriver = function (options) { // We don't support $near and other geo-queries so it's OK to initialize the // comparator only once in the constructor. - var sorter = new Minimongo.Sorter(sortSpec); - var comparator = sorter.getComparator(); var heapOptions = { IdMap: LocalCollection._IdMap }; self._limit = self._cursorDescription.options.limit; self._comparator = comparator; @@ -87,8 +87,8 @@ OplogObserveDriver = function (options) { // Projection function, result of combining important fields for selector and // existing fields projection self._sharedProjection = self._matcher.combineIntoProjection(projection); - if (sortSpec) - self._sharedProjection = Minimongo.Sorter.combineSpecIntoProjection(sortSpec, self._sharedProjection); + if (sorter) + self._sharedProjection = sorter.combineIntoProjection(self._sharedProjection); self._sharedProjectionFn = LocalCollection._compileProjection( self._sharedProjection);