     calls = queue.map (message, i) ->
       { method: "#{message.method.method ? message.method}", called: no }
 
-    workQueue = queue.map (message, i) -> ->
+    workQueue = queue.map (message, i) -> (fin) ->
 
       start = new Date()
 

  bongo.once 'dbClientReady', callback

module.exports = (options = {}) ->
  { dash }    = require 'bongo'
  RateLimit   = require('ratelimit.js').RateLimit
  bongo       = this


        bongo.scrubResponse callbackId, args, (message) ->
          responses[i] = message
          calls[i].called = yes
          fin()

    observeQueue queueId, calls, responses, callback

    async.parallel workQueue, ->
      callback responses  if OBSERVE_QUEUE[queueId]
      OBSERVE_QUEUE[queueId] = null

