       else
         [index]
 
-      # subscribe to collection firehose -> cache. The firehose isn't updated until after mongo,
+      # subscribe to collection firehose -> cache. The firehose isn't updated until after the db,
       # so if we get notified about an op here, the document's been saved.
       @_subscribeChannels channels, (err, stream) =>
         return callback err if err
 
-        # Issue query on mongo to get our initial result set.
-        #console.log 'snapshotdb query', cName, query
-        db.query this, index, query, (err, results) =>
-          #console.log '-> pshotdb query', cName, query, results
+        # Issue query on db to get our initial result set.
+        # console.log 'snapshotdb query', cName, query
+        db.query this, index, query, (err, resultset) =>
+          #console.log '-> pshotdb query', cName, query, resultset
           if err
             stream.destroy()
             return callback err

          emitter.destroy = ->
            stream.destroy()

          if !Array.isArray results
            # Results is an object. It should look like {results:[..], data:....}
            emitter.extra = results.extra
            results = results.results

          emitter.data = results


{Readable} = require 'stream'
{EventEmitter} = require 'events'
assert = require 'assert'
deepEquals = require 'deep-is'
redisLib = require 'redis'
arraydiff = require 'arraydiff'
ot = require './ot'
