nexus - npm Package Compare versions

Comparing version 0.4.0 to 0.4.1

lib/server/connection.js

@@ -102,4 +102,3 @@ 'use strict';
       for (var key in subscriptions) {
-        var sub = subscriptions[key];
-        sub.push(null);
+        this.unsubscribe(key);
       }
@@ -111,2 +110,20 @@
     /**
+     * Unsubscribe from a `document`.
+     *
+     * @param {String} document
+     */
+
+  }, {
+    key: 'unsubscribe',
+    value: function unsubscribe(document) {
+      var subscriptions = this.subscriptions;
+
+      var sub = subscriptions[document];
+      if (!sub) return;
+
+      sub.push(null);
+      delete subscriptions[document];
+    }
+
+    /**
      * Send a `message` to the client.
@@ -232,3 +249,3 @@ *
     key: 'sendUnsubscribe',
-    value: function sendUnsubscribe() {
+    value: function sendUnsubscribe(document) {
       this.send({
@@ -594,3 +611,3 @@ action: 'unsubscribe',
       var _ref7 = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee7(message) {
-        var document, subscriptions, sub;
+        var document;
         return regeneratorRuntime.wrap(function _callee7$(_context7) {
@@ -600,13 +617,8 @@ while (1) {
               case 0:
-                document = message.document, subscriptions = message.subscriptions;
-                sub = subscriptions[document];
+                document = message.document;
 
-
-                if (sub) {
-                  sub.push(null);
-                }
-
+                this.unsubscribe(document);
                 this.sendUnsubscribe(document);
 
-              case 4:
+              case 3:
               case 'end':
@@ -613,0 +625,0 @@ return _context7.stop();

package.json

 {
   "name": "nexus",
-  "version": "0.4.0",
+  "version": "0.4.1",
   "main": "./lib/index.js",
@@ -5,0 +5,0 @@ "files": [

No alert changes

Improved metrics

Total package byte prevSize

117274

increased by0.16%

Lines of code

3066

increased by0.33%

No dependency changes