         @create2 '_p1', {x:5, i:1}, => @create2 '_p2', {x:5, i:2}, => @create2 '_p3', {x:5, i:3}, => callback()
 
       it 'respects limit queries', (done) ->
-        @collection.query {$query:{'x':5}, $orderby:{'i':1}, $limit:1}, {poll:true}, (err, emitter) ->
+        @collection.query @client, {$query:{'x':5}, $orderby:{'i':1}, $limit:1}, {poll:true}, (err, emitter) ->
           assert.strictEqual emitter.data.length, 1
           assert.strictEqual emitter.data[0].docName, '_p1'
           done()
 
       it 'respects skips', (done) ->
-        @collection.query {$query:{'x':5}, $orderby:{'i':1}, $limit:1, $skip:1}, {poll:true}, (err, emitter) ->
+        @collection.query @client, {$query:{'x':5}, $orderby:{'i':1}, $limit:1, $skip:1}, {poll:true}, (err, emitter) ->
           assert.strictEqual emitter.data.length, 1
           assert.strictEqual emitter.data[0].docName, '_p2'
           done()
 
       it 'will insert an element in the set', (done) ->
-        @collection.query {$query:{'x':5}, $orderby:{'i':1}}, {poll:true}, (err, emitter) =>
+        @collection.query @client, {$query:{'x':5}, $orderby:{'i':1}}, {poll:true}, (err, emitter) =>
           assert.equal emitter.data.length, 3
 
           emitter.on 'diff', (diff) =>


    describe 'extra data', ->
      it 'gets extra data in the initial result set', (done) ->
        @testWrapper.query = (cName, query, callback) ->
          callback null, {results:[], extra:{x:5}}

        @client.query 'internet', {x:5}, {backend:'test'}, (err, stream) =>

            done()

      it 'adds an element when it matches', (done) ->
        @collection.query @client, {'x':5}, opts, (err, emitter) =>
          emitter.on 'diff', (diff) =>
            assert.deepEqual diff, [
              index: 0
