Removed babel-transform-runtime. Updated to Node 10.6.0.

.airtap.yml

@@ -3,9 +3,6 @@ browsers:
   - name: chrome
     version: latest
     platform: Windows 10
-  - name: internet explorer
-    version: latest
-    platform: Windows 10
   - name: firefox
     version: latest
     platform: Windows 10

README.md

@@ -1,6 +1,6 @@
 # readable-stream
 
-***Node.js core v10.5.0 streams for userland*** [![Build Status](https://travis-ci.com/nodejs/readable-stream.svg?branch=master)](https://travis-ci.com/nodejs/readable-stream)
+***Node.js core streams for userland*** [![Build Status](https://travis-ci.com/nodejs/readable-stream.svg?branch=master)](https://travis-ci.com/nodejs/readable-stream)
 
 
 [![NPM](https://nodei.co/npm/readable-stream.png?downloads=true&downloadRank=true)](https://nodei.co/npm/readable-stream/)
@@ -13,11 +13,9 @@
 npm install --save readable-stream
 ```
 
-***Node.js core streams for userland***
-
 This package is a mirror of the streams implementations in Node.js.
 
-Full documentation may be found on the [Node.js website](https://nodejs.org/dist/v10.5.0/docs/api/stream.html).
+Full documentation may be found on the [Node.js website](https://nodejs.org/dist/v10.6.0/docs/api/stream.html).
 
 If you want to guarantee a stable streams base, regardless of what version of
 Node you, or the users of your libraries are using, use **readable-stream** *only* and avoid the *"stream"* module in Node-core, for background see [this blogpost](http://r.va.gg/2014/06/why-i-dont-use-nodes-core-stream-module.html).

build/build.js

@@ -76,8 +76,7 @@ function processFile (inputLoc, out, replacements, addAtEnd) {
             'transform-optional-catch-binding',
             'transform-inline-imports-commonjs',
             'transform-async-to-generator',
-            'transform-async-generator-functions',
-            'transform-runtime',
+            'transform-async-generator-functions'
           ]
         })
         data = transformed.code

lib/_stream_duplex.js

@@ -28,19 +28,11 @@
 
 /*<replacement>*/
 
-var _keys;
-
-function _load_keys() {
-  return _keys = _interopRequireDefault(require('babel-runtime/core-js/object/keys'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var pna = require('process-nextick-args');
 /*</replacement>*/
 
 /*<replacement>*/
-var objectKeys = (_keys || _load_keys()).default || function (obj) {
+var objectKeys = Object.keys || function (obj) {
   var keys = [];
   for (var key in obj) {
     keys.push(key);

lib/_stream_readable.js

@@ -23,26 +23,6 @@
 
 /*<replacement>*/
 
-var _symbol;
-
-function _load_symbol() {
-  return _symbol = _interopRequireDefault(require('babel-runtime/core-js/symbol'));
-}
-
-var _isNan;
-
-function _load_isNan() {
-  return _isNan = _interopRequireDefault(require('babel-runtime/core-js/number/is-nan'));
-}
-
-var _getPrototypeOf;
-
-function _load_getPrototypeOf() {
-  return _getPrototypeOf = _interopRequireDefault(require('babel-runtime/core-js/object/get-prototype-of'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var pna = require('process-nextick-args');
 /*</replacement>*/
 
@@ -289,7 +269,7 @@ function readableAddChunk(stream, chunk, encoding, addToFront, skipChunkCheck) {
     if (er) {
       stream.emit('error', er);
     } else if (state.objectMode || chunk && chunk.length > 0) {
-      if (typeof chunk !== 'string' && !state.objectMode && (0, (_getPrototypeOf || _load_getPrototypeOf()).default)(chunk) !== Buffer.prototype) {
+      if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prototype) {
         chunk = _uint8ArrayToBuffer(chunk);
       }
 
@@ -379,7 +359,7 @@ function computeNewHighWaterMark(n) {
 function howMuchToRead(n, state) {
   if (n <= 0 || state.length === 0 && state.ended) return 0;
   if (state.objectMode) return 1;
-  if ((0, (_isNan || _load_isNan()).default)(n)) {
+  if (Number.isNaN(n)) {
     // Only flow one buffer at a time
     if (state.flowing && state.length) return state.buffer.head.data.length;else return state.length;
   }
@@ -958,7 +938,7 @@ Readable.prototype.wrap = function (stream) {
   return this;
 };
 
-Readable.prototype[(_symbol || _load_symbol()).default.asyncIterator] = function () {
+Readable.prototype[Symbol.asyncIterator] = function () {
   emitExperimentalWarning('Readable[Symbol.asyncIterator]');
   if (ReadableAsyncIterator === undefined) ReadableAsyncIterator = require('./internal/streams/async_iterator');
   return new ReadableAsyncIterator(this);

lib/_stream_writable.js

@@ -27,32 +27,6 @@
 
 /*<replacement>*/
 
-var _defineProperty;
-
-function _load_defineProperty() {
-  return _defineProperty = _interopRequireDefault(require('babel-runtime/core-js/object/define-property'));
-}
-
-var _hasInstance;
-
-function _load_hasInstance() {
-  return _hasInstance = _interopRequireDefault(require('babel-runtime/core-js/symbol/has-instance'));
-}
-
-var _symbol;
-
-function _load_symbol() {
-  return _symbol = _interopRequireDefault(require('babel-runtime/core-js/symbol'));
-}
-
-var _setImmediate2;
-
-function _load_setImmediate() {
-  return _setImmediate2 = _interopRequireDefault(require('babel-runtime/core-js/set-immediate'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var pna = require('process-nextick-args');
 /*</replacement>*/
 
@@ -80,7 +54,7 @@ function CorkedRequest(state) {
 /* </replacement> */
 
 /*<replacement>*/
-var asyncWrite = !process.browser && ['v0.10', 'v0.9.'].indexOf(process.version.slice(0, 5)) > -1 ? (_setImmediate2 || _load_setImmediate()).default : pna.nextTick;
+var asyncWrite = !process.browser && ['v0.10', 'v0.9.'].indexOf(process.version.slice(0, 5)) > -1 ? setImmediate : pna.nextTick;
 /*</replacement>*/
 
 /*<replacement>*/
@@ -257,9 +231,9 @@ WritableState.prototype.getBuffer = function getBuffer() {
 // Test _writableState for inheritance to account for Duplex streams,
 // whose prototype chain only points to Readable.
 var realHasInstance;
-if (typeof (_symbol || _load_symbol()).default === 'function' && (_hasInstance || _load_hasInstance()).default && typeof Function.prototype[(_hasInstance || _load_hasInstance()).default] === 'function') {
-  realHasInstance = Function.prototype[(_hasInstance || _load_hasInstance()).default];
-  (0, (_defineProperty || _load_defineProperty()).default)(Writable, (_hasInstance || _load_hasInstance()).default, {
+if (typeof Symbol === 'function' && Symbol.hasInstance && typeof Function.prototype[Symbol.hasInstance] === 'function') {
+  realHasInstance = Function.prototype[Symbol.hasInstance];
+  Object.defineProperty(Writable, Symbol.hasInstance, {
     value: function (object) {
       if (realHasInstance.call(this, object)) return true;
       if (this !== Writable) return false;

lib/internal/streams/async_iterator.js

@@ -2,45 +2,23 @@
 
 /*<replacement>*/
 
-var _promise;
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
 
-function _load_promise() {
-  return _promise = _interopRequireDefault(require('babel-runtime/core-js/promise'));
-}
-
-var _createClass2;
-
-function _load_createClass() {
-  return _createClass2 = _interopRequireDefault(require('babel-runtime/helpers/createClass'));
-}
-
-var _classCallCheck2;
-
-function _load_classCallCheck() {
-  return _classCallCheck2 = _interopRequireDefault(require('babel-runtime/helpers/classCallCheck'));
-}
-
-var _symbol;
-
-function _load_symbol() {
-  return _symbol = _interopRequireDefault(require('babel-runtime/core-js/symbol'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
 
 var pna = require('process-nextick-args');
 /*</replacement>*/
 
-var kLastResolve = (0, (_symbol || _load_symbol()).default)('lastResolve');
-var kLastReject = (0, (_symbol || _load_symbol()).default)('lastReject');
-var kError = (0, (_symbol || _load_symbol()).default)('error');
-var kEnded = (0, (_symbol || _load_symbol()).default)('ended');
-var kLastPromise = (0, (_symbol || _load_symbol()).default)('lastPromise');
-var kHandlePromise = (0, (_symbol || _load_symbol()).default)('handlePromise');
-var kStream = (0, (_symbol || _load_symbol()).default)('stream');
+var kLastResolve = Symbol('lastResolve');
+var kLastReject = Symbol('lastReject');
+var kError = Symbol('error');
+var kEnded = Symbol('ended');
+var kLastPromise = Symbol('lastPromise');
+var kHandlePromise = Symbol('handlePromise');
+var kStream = Symbol('stream');
 
 var AsyncIteratorRecord = function AsyncIteratorRecord(value, done) {
-  (0, (_classCallCheck2 || _load_classCallCheck()).default)(this, AsyncIteratorRecord);
+  _classCallCheck(this, AsyncIteratorRecord);
 
   this.done = done;
   this.value = value;
@@ -104,7 +82,7 @@ var ReadableAsyncIterator = function () {
   function ReadableAsyncIterator(stream) {
     var _this = this;
 
-    (0, (_classCallCheck2 || _load_classCallCheck()).default)(this, ReadableAsyncIterator);
+    _classCallCheck(this, ReadableAsyncIterator);
 
     this[kStream] = stream;
     this[kLastResolve] = null;
@@ -139,11 +117,11 @@ var ReadableAsyncIterator = function () {
     // reject straight away
     var error = this[kError];
     if (error !== null) {
-      return (_promise || _load_promise()).default.reject(error);
+      return Promise.reject(error);
     }
 
     if (this[kEnded]) {
-      return (_promise || _load_promise()).default.resolve(new AsyncIteratorRecord(null, true));
+      return Promise.resolve(new AsyncIteratorRecord(null, true));
     }
 
     // if we have multiple next() calls
@@ -154,16 +132,16 @@ var ReadableAsyncIterator = function () {
     var promise = void 0;
 
     if (lastPromise) {
-      promise = new (_promise || _load_promise()).default(wrapForNext(lastPromise, this));
+      promise = new Promise(wrapForNext(lastPromise, this));
     } else {
       // fast path needed to support multiple this.push()
       // without triggering the next() queue
       var data = this[kStream].read();
       if (data !== null) {
-        return (_promise || _load_promise()).default.resolve(new AsyncIteratorRecord(data, false));
+        return Promise.resolve(new AsyncIteratorRecord(data, false));
       }
 
-      promise = new (_promise || _load_promise()).default(this[kHandlePromise]);
+      promise = new Promise(this[kHandlePromise]);
     }
 
     this[kLastPromise] = promise;
@@ -177,7 +155,7 @@ var ReadableAsyncIterator = function () {
     // destroy(err, cb) is a private API
     // we can guarantee we have that here, because we control the
     // Readable class this is attached to
-    return new (_promise || _load_promise()).default(function (resolve, reject) {
+    return new Promise(function (resolve, reject) {
       _this2[kStream].destroy(null, function (err) {
         if (err) {
           reject(err);
@@ -188,12 +166,13 @@ var ReadableAsyncIterator = function () {
     });
   };
 
-  (0, (_createClass2 || _load_createClass()).default)(ReadableAsyncIterator, [{
+  _createClass(ReadableAsyncIterator, [{
     key: 'stream',
     get: function () {
       return this[kStream];
     }
   }]);
+
   return ReadableAsyncIterator;
 }();
 

lib/internal/streams/buffer_list.js

@@ -1,12 +1,6 @@
 'use strict';
 
-var _classCallCheck2;
-
-function _load_classCallCheck() {
-  return _classCallCheck2 = _interopRequireDefault(require('babel-runtime/helpers/classCallCheck'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
 
 var Buffer = require('buffer').Buffer;
 var util = require('util');
@@ -20,7 +14,7 @@ function copyBuffer(src, target, offset) {
 
 module.exports = function () {
   function BufferList() {
-    (0, (_classCallCheck2 || _load_classCallCheck()).default)(this, BufferList);
+    _classCallCheck(this, BufferList);
 
     this.head = null;
     this.tail = null;

lib/internal/streams/state.js

@@ -2,14 +2,6 @@
 
 /*<replacement>*/
 
-var _isInteger;
-
-function _load_isInteger() {
-  return _isInteger = _interopRequireDefault(require('babel-runtime/core-js/number/is-integer'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var pna = require('process-nextick-args');
 /*</replacement>*/
 
@@ -22,7 +14,7 @@ function highWaterMarkFrom(options, isDuplex, duplexKey) {
 function getHighWaterMark(state, options, duplexKey, isDuplex) {
   var hwm = highWaterMarkFrom(options, isDuplex, duplexKey);
   if (hwm != null) {
-    if (!(0, (_isInteger || _load_isInteger()).default)(hwm) || hwm < 0) {
+    if (!Number.isInteger(hwm) || hwm < 0) {
       var name = isDuplex ? duplexKey : 'highWaterMark';
       throw new ERR_INVALID_OPT_VALUE(name, hwm);
     }

package.json

@@ -27,7 +27,6 @@
     "babel-plugin-transform-es2015-spread": "^6.22.0",
     "babel-plugin-transform-es2015-template-literals": "^6.8.0",
     "babel-plugin-transform-inline-imports-commonjs": "^1.2.0",
-    "babel-plugin-transform-runtime": "^6.23.0",
     "babel-polyfill": "^6.9.1",
     "babel-preset-env": "^1.7.0",
     "bl": "^2.0.0",

test/common/benchmark.js

@@ -1,13 +1,5 @@
 'use strict';
 
-var _assign;
-
-function _load_assign() {
-  return _assign = _interopRequireDefault(require('babel-runtime/core-js/object/assign'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 /*<replacement>*/
 require('babel-polyfill');
 var util = require('util');
@@ -42,12 +34,26 @@ function runBenchmark(name, args, env) {
 
   argv.push(name);
 
-  var mergedEnv = (0, (_assign || _load_assign()).default)({}, process.env, env);
+  var mergedEnv = Object.assign({}, process.env, env);
+
+  var child = fork(runjs, argv, { env: mergedEnv, stdio: 'pipe' });
+  child.stdout.setEncoding('utf8');
+
+  var stdout = '';
+  child.stdout.on('data', function (line) {
+    stdout += line;
+  });
 
-  var child = fork(runjs, argv, { env: mergedEnv });
   child.on('exit', function (code, signal) {
     assert.strictEqual(code, 0);
     assert.strictEqual(signal, null);
+    // This bit makes sure that each benchmark file is being sent settings such
+    // that the benchmark file runs just one set of options. This helps keep the
+    // benchmark tests from taking a long time to run. Therefore, each benchmark
+    // file should result in three lines of output: a blank line, a line with
+    // the name of the benchmark file, and a line with the only results that we
+    // get from testing the benchmark file.
+    assert.ok(/^(?:\n.+?\n.+?\n)+$/.test(stdout), 'benchmark file not running exactly one configuration in test: ' + stdout);
   });
 }