Test implementation of client list

gistfile1.txt

MemoryPersistence.prototype.getClientList = function (topic, cb) {
  var that = this
  getClients(topic, function getClients(clientList) {
    var count = 0
    cb(from2.obj(function match(size, next) {
      if (count >= clientList.length) return next(null, null) 
        var chunk = clientList[count]
        count++ 
        next(null, chunk)
    }))
  })


  function getClients(topic, done) {
    var clientSubs = that._subscriptions
    var keys = Object.keys(clientSubs)
    var subs = []
    keys.forEach(function clientKey (client, index) {
        clientSubs[client].forEach(function (sub) {
            console.log(sub)
            if (sub.topic === topic) {
                subs.push(sub.clientId)
            }
        })
        if (index === keys.length - 1) {
            done(subs)
        }
    })
  }
}