             throw new Error err if err
 
       it 'does not emit receive events to a destroyed query', (done) ->
-        @collection.query {'x':5}, opts, (err, emitter) =>
+        @collection.query @client, {'x':5}, opts, (err, emitter) =>
           emitter.on 'diff', -> throw new Error 'add called after destroy'
 
           emitter.destroy()


      it 'gets updated extra data when the result set changes', (done) ->
        x = 1
        @testWrapper.query = (cName, query, callback) ->
          callback null, {results:[], extra:{x:x++}}

        @collection.query {x:5}, {backend:'test'}, (err, stream) =>
          assert.deepEqual stream.extra, {x:1}
          
          stream.on 'extra', (extra) ->


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

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