amqp-as-promised - npm Package Compare versions

Comparing version 2.0.1 to 2.1.0

lib/amqp-client.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var ExchangeWrapper, Q, QueueWrapper, amqp, log;

lib/compressor.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -33,3 +33,3 @@ var I, Q, comp, compress, decomp, decompress, jsonp, plug, zlib;
     return Q.Promise(function(rs, rj) {
-      var err, error;
+      var err;
       try {
@@ -36,0 +36,0 @@ return rs(JSON.parse(str));

lib/exchange-wrapper.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var ExchangeWrapper, Q;

lib/index.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var Rpc, RpcBackend, amqpClient, log;

lib/merge.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var slice = [].slice;

lib/queue-wrapper.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -102,3 +102,3 @@ var Q, QueueWrapper, log,
           wrapper = function() {
-            var err, error;
+            var err;
             try {
@@ -117,2 +117,4 @@ return callb.apply(null, arguments);
             return def.resolve(_this);
+          }).addErrback(function(err) {
+            return def.reject(err);
           });
@@ -133,5 +135,10 @@ };
       delete this._ctag;
-      this.queue.unsubscribe(ctag);
-      log.info('unsubscribed:', this.name, ctag);
-      def.resolve(this);
+      (this.queue.unsubscribe(ctag)).addCallback((function(_this) {
+        return function() {
+          log.info('unsubscribed:', _this.name, ctag);
+          return def.resolve(_this);
+        };
+      })(this)).addErrback(function(err) {
+        return def.reject(err);
+      });
       return def.promise;
@@ -138,0 +145,0 @@ };

lib/rpc-backend.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var Q, RpcBackend, compress, decompress, doack, log, merge, ref,

lib/rpc.js

@@ -1,2 +0,2 @@
-// Generated by CoffeeScript 1.10.0
+// Generated by CoffeeScript 1.11.1
 (function() {
@@ -3,0 +3,0 @@ var Cache, DEFAULT_TIMEOUT, Q, Rpc, compress, decompress, merge, ref, uuid,

package.json

 {
   "name": "amqp-as-promised",
   "description": "A promise-based AMQP API build on node-amqp",
-  "version": "2.0.1",
+  "version": "2.1.0",
   "repository": {
@@ -26,3 +26,3 @@ "type": "git",
     "q": "~1.4.1",
-    "amqp": "0.2.4",
+    "amqp": "0.2.6",
     "uuid": "~2.0.1",
@@ -29,0 +29,0 @@ "bog": "1",

No alert changes

Improved metrics

Total package byte prevSize

93340

increased by0.38%

Lines of code

769

increased by0.92%

Dependency changes

• + Addedamqp@0.2.6(transitive)

• + Addedlodash@4.17.21(transitive)

• - Removedamqp@0.2.4(transitive)

• - Removedlodash@1.3.1(transitive)

• Updatedamqp@0.2.6