readable-stream - npm Package Compare versions

Comparing version 3.0.0-rc.1 to 3.0.0-rc.2

lib/_stream_duplex.js

@@ -31,10 +31,2 @@ // Copyright Joyent, Inc. and other Node contributors.
 
-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');
@@ -44,3 +36,3 @@ /*</replacement>*/
 /*<replacement>*/
-var objectKeys = (_keys || _load_keys()).default || function (obj) {
+var objectKeys = Object.keys || function (obj) {
   var keys = [];
@@ -47,0 +39,0 @@ for (var key in obj) {

lib/_stream_readable.js

@@ -26,22 +26,2 @@ // Copyright Joyent, Inc. and other Node contributors.
 
-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');
@@ -293,3 +273,3 @@ /*</replacement>*/
     } 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);
@@ -384,3 +364,3 @@ }
   if (state.objectMode) return 1;
-  if ((0, (_isNan || _load_isNan()).default)(n)) {
+  if (Number.isNaN(n)) {
     // Only flow one buffer at a time
@@ -964,3 +944,3 @@ if (state.flowing && state.length) return state.buffer.head.data.length;else return state.length;
 
-Readable.prototype[(_symbol || _load_symbol()).default.asyncIterator] = function () {
+Readable.prototype[Symbol.asyncIterator] = function () {
   emitExperimentalWarning('Readable[Symbol.asyncIterator]');
@@ -967,0 +947,0 @@ if (ReadableAsyncIterator === undefined) ReadableAsyncIterator = require('./internal/streams/async_iterator');

lib/_stream_writable.js

@@ -30,28 +30,2 @@ // Copyright Joyent, Inc. and other Node contributors.
 
-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');
@@ -84,3 +58,3 @@ /*</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>*/
@@ -262,5 +236,5 @@
 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) {
@@ -267,0 +241,0 @@ if (realHasInstance.call(this, object)) return true;

lib/internal/streams/async_iterator.js

@@ -5,41 +5,19 @@ 'use strict';
 
-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'));
-}
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
 
-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 }; }
-
 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);
 
@@ -108,3 +86,3 @@ this.done = done;
 
-    (0, (_classCallCheck2 || _load_classCallCheck()).default)(this, ReadableAsyncIterator);
+    _classCallCheck(this, ReadableAsyncIterator);
 
@@ -144,7 +122,7 @@ this[kStream] = stream;
     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));
     }
@@ -160,3 +138,3 @@
     if (lastPromise) {
-      promise = new (_promise || _load_promise()).default(wrapForNext(lastPromise, this));
+      promise = new Promise(wrapForNext(lastPromise, this));
     } else {
@@ -167,6 +145,6 @@ // fast path needed to support multiple this.push()
       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]);
     }
@@ -185,3 +163,3 @@
     // 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) {
@@ -197,3 +175,3 @@ if (err) {
 
-  (0, (_createClass2 || _load_createClass()).default)(ReadableAsyncIterator, [{
+  _createClass(ReadableAsyncIterator, [{
     key: 'stream',
@@ -204,2 +182,3 @@ get: function () {
   }]);
+
   return ReadableAsyncIterator;
@@ -206,0 +185,0 @@ }();

lib/internal/streams/buffer_list.js

 'use strict';
 
-var _classCallCheck2;
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
 
-function _load_classCallCheck() {
-  return _classCallCheck2 = _interopRequireDefault(require('babel-runtime/helpers/classCallCheck'));
-}
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var Buffer = require('buffer').Buffer;
@@ -23,3 +17,3 @@ var util = require('util');
   function BufferList() {
-    (0, (_classCallCheck2 || _load_classCallCheck()).default)(this, BufferList);
+    _classCallCheck(this, BufferList);
 
@@ -26,0 +20,0 @@ this.head = null;

lib/internal/streams/state.js

@@ -5,10 +5,2 @@ 'use strict';
 
-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');
@@ -26,3 +18,3 @@ /*</replacement>*/
   if (hwm != null) {
-    if (!(0, (_isInteger || _load_isInteger()).default)(hwm) || hwm < 0) {
+    if (!Number.isInteger(hwm) || hwm < 0) {
       var name = isDuplex ? duplexKey : 'highWaterMark';
@@ -29,0 +21,0 @@ throw new ERR_INVALID_OPT_VALUE(name, hwm);

package.json

 {
   "name": "readable-stream",
-  "version": "3.0.0-rc.1",
+  "version": "3.0.0-rc.2",
   "description": "Streams3, a user-land copy of the stream library from Node.js",
@@ -30,3 +30,2 @@ "main": "readable.js",
     "babel-plugin-transform-inline-imports-commonjs": "^1.2.0",
-    "babel-plugin-transform-runtime": "^6.23.0",
     "babel-polyfill": "^6.9.1",
@@ -33,0 +32,0 @@ "babel-preset-env": "^1.7.0",

README.md

 # 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)
 
@@ -16,7 +16,5 @@
 
-***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).
 
@@ -23,0 +21,0 @@ If you want to guarantee a stable streams base, regardless of what version of

No alert changes

Improved metrics

Dev dependency count

33

decreased by-2.94%

Worsened metrics

Total package byte prevSize

110599

decreased by-2.44%

Lines of code

2480

decreased by-2.29%

Number of lines in readme file

62

decreased by-3.12%

No dependency changes