v16.0.1

Author: jondubois

package.json

@@ -45,7 +45,6 @@
   "devDependencies": {
     "@babel/core": "^7.7.4",
     "@babel/preset-env": "^7.7.4",
-    "socketcluster-server": "^16.0.0",
     "babel-plugin-minify-dead-code-elimination": "^0.5.0",
     "browserify": "^16.2.3",
     "es-check": "^5.1.0",
@@ -58,6 +57,7 @@
     "gulp-uglify": "^3.0.1",
     "localStorage": "^1.0.3",
     "mocha": "^5.2.0",
+    "socketcluster-server": "^16.0.0",
     "uglify-es": "^3.3.9",
     "vinyl-source-stream": "^2.0.0"
   }

socketcluster-client.js

@@ -1,5 +1,5 @@
 /**
- * SocketCluster JavaScript client v15.1.0
+ * SocketCluster JavaScript client v16.0.0
  */
  (function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.socketClusterClient = f()}})(function(){var define,module,exports;return (function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i<t.length;i++)o(t[i]);return o}return r})()({1:[function(require,module,exports){
 (function (global){
@@ -4465,15 +4465,6 @@ class ConsumableStream {
     throw new TypeError('Method must be overriden by subclass');
   }
 
-  createConsumable(timeout) {
-    let asyncIterator = this.createConsumer(timeout);
-    return {
-      [Symbol.asyncIterator]: () => {
-        return asyncIterator;
-      }
-    }
-  }
-
   [Symbol.asyncIterator]() {
     return this.createConsumer();
   }
@@ -6362,7 +6353,7 @@ class Consumer {
     this.stream = stream;
     this.currentNode = startNode;
     this.timeout = timeout;
-    this._isIterating = false;
+    this.isAlive = true;
     this.stream.setConsumer(this.id, this);
   }
 
@@ -6377,7 +6368,7 @@ class Consumer {
     return stats;
   }
 
-  resetBackpressure() {
+  _resetBackpressure() {
     this._backpressure = 0;
   }
 
@@ -6410,19 +6401,21 @@ class Consumer {
       clearTimeout(this._timeoutId);
       delete this._timeoutId;
     }
-    if (this._isIterating) {
-      this._killPacket = {value, done: true};
-      this.applyBackpressure(this._killPacket);
-    } else {
-      this.stream.removeConsumer(this.id);
-      this.resetBackpressure();
-    }
+    this._killPacket = {value, done: true};
+    this._destroy();
+
     if (this._resolve) {
       this._resolve();
       delete this._resolve;
     }
   }
 
+  _destroy() {
+    this.isAlive = false;
+    this._resetBackpressure();
+    this.stream.removeConsumer(this.id);
+  }
+
   async _waitForNextItem(timeout) {
     return new Promise((resolve, reject) => {
       this._resolve = resolve;
@@ -6445,23 +6438,19 @@ class Consumer {
   }
 
   async next() {
-    this._isIterating = true;
     this.stream.setConsumer(this.id, this);
 
     while (true) {
       if (!this.currentNode.next) {
         try {
           await this._waitForNextItem(this.timeout);
         } catch (error) {
-          this._isIterating = false;
-          this.stream.removeConsumer(this.id);
+          this._destroy();
           throw error;
         }
       }
       if (this._killPacket) {
-        this._isIterating = false;
-        this.stream.removeConsumer(this.id);
-        this.resetBackpressure();
+        this._destroy();
         let killPacket = this._killPacket;
         delete this._killPacket;
 
@@ -6476,8 +6465,7 @@ class Consumer {
       }
 
       if (this.currentNode.data.done) {
-        this._isIterating = false;
-        this.stream.removeConsumer(this.id);
+        this._destroy();
       }
 
       return this.currentNode.data;
@@ -6486,11 +6474,13 @@ class Consumer {
 
   return() {
     delete this.currentNode;
-    this._isIterating = false;
-    this.stream.removeConsumer(this.id);
-    this.resetBackpressure();
+    this._destroy();
     return {};
   }
+
+  [Symbol.asyncIterator]() {
+    return this;
+  }
 }
 
 function wait(timeout) {