         while @_cbQueue[0]?
             # If there's no more data let's notify the waiting callback
             if not @hasNext()
-                cb = @_cbQueue.shift()
+                cb = @_getCallback()
                 cb new err.RqlDriverError "No more rows in the cursor."
             else
                 # Try to get a row out of the responses


    _handleRow: ->
        response = @_responses[0]

        row = deconstructDatum(response.response[@_responseIndex], @_opts)
        cb = @_getCallback()



    ## Implement IterableResult

    hasNext: ar () -> @_responses[0]? && @_responses[0].response.length > 0

    next: ar (cb) ->
        nextCbCheck(cb)
