     request
       uri: @_urlToDocument("_design/events/_view/byAggregate?key=\"#{aggregateUid}\"")
       json: {}
-    , (err, response, body) ->
+    , (err, response, body) =>
       if err?
         callback err
       else

      data         = value.data
      attachments  = value._attachments

      if options.loadBlobs and attachments?
        attachmentsQueue = async.queue (attachment, attachmentCallback) =>
          request

        , 1

        attachmentsQueue.drain = ->
          pushEvent rowCallback

        for k, _ of attachments
          attachmentsQueue.push k
      else
        pushEvent rowCallback
    , 1

    rowsQueue.drain = ->
