     queue = []
 
     if dropFirst
-      queue.push -> collection.drop -> queue.next()
+      queue.push (next) -> collection.drop -> next()
 
-    queue.push ->
+    queue.push (next) ->
       csv()
         .from.path(path, { delimiter, encoding })
         .to.stream(stream)

          collection.insert doc, (err) ->
            return stream.emit 'error', err  if err
        )
        .on 'close', -> queue.next()

    queue.push ->
      collection.createIndex 'zip'

    daisy queue

  return stream

fs            = require 'fs'
csv           = require 'csv'
async         = require 'async'
nodePath      = require 'path'
{Stream}      = require 'stream'
{MongoClient} = require 'mongodb'


fetchDb = (mongo, callback) ->
