updated from moscajs#449

adpdigital · Apr 22, 2016 · 0522b26 · 0522b26
1 parent 6dc28e8
commit 0522b26
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 19 deletions.
diff --git a/lib/persistence/abstract.js b/lib/persistence/abstract.js
@@ -138,22 +138,6 @@ AbstractPersistence.prototype.wire = function(server) {
   };
 };
 
-function arrayFrom(object) {
-  return [].slice.call(object);
-}
-
-/**
- * Array.from polyfill
- * @param aSet the set to changed to an array
- */
-AbstractPersistence.prototype.arrayFrom = function(aSet) {
-  if (Array.from) {
-    return Array.from(aSet);
-  } else {
-    return arrayFrom(aSet);
-  }
-};
-
 /**
  * Close the persistance.
  *

diff --git a/lib/persistence/levelup.js b/lib/persistence/levelup.js
@@ -230,7 +230,7 @@ LevelUpPersistence.prototype.lookupSubscriptions = function(client, done) {
 LevelUpPersistence.prototype.storeOfflinePacket = function(packet, done) {
   var that = this;
   var subs = this._subMatcher.match(packet.topic);
-  async.each(this.arrayFrom(subs), function(key, cb) {
+  async.each(subs, function(key, cb) {
     that._subscriptions.get(key, function(err, sub) {
       if (err) {
         return cb(err);

diff --git a/lib/persistence/redis.js b/lib/persistence/redis.js
@@ -334,7 +334,7 @@ RedisPersistence.prototype.storeOfflinePacket = function(packet, done) {
   var that = this;
 
   var matches = this._subMatcher.match(packet.topic);
-  async.each(this.arrayFrom(matches), function(client, cb) {
+  async.each(matches, function(client, cb) {
     that._storePacket(client, packet, cb);
   }, done);
 };

diff --git a/package.json b/package.json
@@ -71,7 +71,7 @@
   },
   "dependencies": {
     "ascoltatori": "^2.0.0",
-    "async": "~1.5.2",
+    "async": "^2.0.0-rc.3",
     "brfs": "~1.4.2",
     "bunyan": "^1.5.1",
     "clone": "^1.0.2",