bench connections using fastq

fastbench.js

// npm install mqtt fastq
// command to run : node fastbench 25000
'use strict'

var queue = require('fastq')(worker, 1)
var mqtt = require('mqtt')
var connected = 1
var clients = []
var count = 0
var st = Date.now()
console.log('Started connecting clients', st)

function worker (arg, cb) {
   clients[count]  = mqtt.connect({
        host: "127.0.0.1",
        port : 1883,
        keepalive : 60
   })
   clients[count].on('connect', function con () {
    connected++
    if (connected == process.argv[2]) {
        console.log('done connecting clients', Date.now() - st)
    }
    cb(null, 42*2)
  })  
  count++
}

for (var i = 0; i < process.argv[2]; i++) {
    queue.push(42, function() {})
}