Add browser tests and use saucelabs to test them.

This also finds and fixes errors related to string encoding and
some compatablity issues which allow it to work as far
back as IE 9 (probably IE 8 with an ES5 shm).

Author: calvinmetcalf

.travis.yml

@@ -1,9 +1,38 @@
 language: node_js
 before_install:
   - npm install -g npm
-node_js:
-  - "0.8"
-  - "0.10"
-  - "0.11"
-  - "0.12"
-  - "iojs"
+notifications:
+  email: false
+matrix:
+  include:
+  - node_js: '0.8'
+    env: TASK=test
+  - node_js: '0.10'
+    env: TASK=test
+  - node_js: '0.11'
+    env: TASK=test
+  - node_js: '0.12'
+    env: TASK=test
+  - node_js: 'iojs'
+    env: TASK=test
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=opera BROWSER_VERSION="11..latest"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=ie BROWSER_VERSION="9..latest"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=chrome BROWSER_VERSION="39..beta"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=firefox BROWSER_VERSION="34..beta"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=ipad BROWSER_VERSION="6.0..latest"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=iphone BROWSER_VERSION="6.0..latest"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=safari BROWSER_VERSION="5..latest"
+  - node_js: 'iojs'
+    env: TASK=browser BROWSER_NAME=android BROWSER_VERSION="4.0..latest"
+script: "npm run $TASK"
+env:
+  global:
+  - secure: rE2Vvo7vnjabYNULNyLFxOyt98BoJexDqsiOnfiD6kLYYsiQGfr/sbZkPMOFm9qfQG7pjqx+zZWZjGSswhTt+626C0t/njXqug7Yps4c3dFblzGfreQHp7wNX5TFsvrxd6dAowVasMp61sJcRnB2w8cUzoe3RAYUDHyiHktwqMc=
+  - secure: g9YINaKAdMatsJ28G9jCGbSaguXCyxSTy+pBO6Ch0Cf57ZLOTka3HqDj8p3nV28LUIHZ3ut5WO43CeYKwt4AUtLpBS3a0dndHdY6D83uY6b2qh5hXlrcbeQTq2cvw2y95F7hm4D1kwrgZ7ViqaKggRcEupAL69YbJnxeUDKWEdI=

.zuul.yml

@@ -0,0 +1 @@
+ui: tape

README.md

@@ -6,6 +6,9 @@
 [![NPM](https://nodei.co/npm/readable-stream.png?downloads=true&downloadRank=true)](https://nodei.co/npm/readable-stream/)
 [![NPM](https://nodei.co/npm-dl/readable-stream.png?&months=6&height=3)](https://nodei.co/npm/readable-stream/)
 
+
+[![Sauce Test Status](https://saucelabs.com/browser-matrix/readable-stream.svg)](https://saucelabs.com/u/readable-stream)
+
 ```bash
 npm install --save readable-stream
 ```

build/common-replacements.js

@@ -26,3 +26,16 @@ module.exports.altIndexOfUseReplacement = [
     /(\W)([\w\.\(\),\[\]]+)(\.indexOf\()/gm
   , '$1indexOf($2, '
 ]
+module.exports.objectKeysDefine = [
+     /^('use strict';)$/m
+   , '$1\n\n/*<replacement>*/\nvar objectKeys = Object.keys || function (obj) {\n'
+     + '  var keys = [];\n'
+     + '  for (var key in obj) keys.push(key);\n'
+     + '  return keys;\n'
+     + '}\n/*</replacement>*/\n'
+]
+
+module.exports.objectKeysReplacement = [
+     /Object\.keys/g
+   , 'objectKeys'
+ ]

build/files.js

@@ -63,10 +63,15 @@ const headRegexp = /(^module.exports = \w+;?)/m
       ]
 
     , objectDefinePropertyReplacement = [
-          /Object.defineProperties/
+          /(Object\.defineProperties)/
       ,   'if (Object.defineProperties) $1'
       ]
-
+    , objectDefinePropertySingReplacement = [
+          /Object\.defineProperty\(([\w\W]+?)\}\);/
+      ,   '(function (){try {\n'
+        + 'Object.defineProperty\($1});\n'
+        + '}catch(_){}}());\n'
+      ]
 
     , isArrayDefine = [
           headRegexp
@@ -78,19 +83,9 @@ const headRegexp = /(^module.exports = \w+;?)/m
         , 'isArray'
       ]
 
-    , objectKeysDefine = [
-          headRegexp
-        , '$1\n\n/*<replacement>*/\nvar objectKeys = Object.keys || function (obj) {\n'
-          + '  var keys = [];\n'
-          + '  for (var key in obj) keys.push(key);\n'
-          + '  return keys;\n'
-          + '}\n/*</replacement>*/\n'
-      ]
+    , objectKeysDefine = require('./common-replacements').objectKeysDefine
 
-    , objectKeysReplacement = [
-          /Object\.keys/g
-        , 'objectKeys'
-      ]
+    , objectKeysReplacement = require('./common-replacements').objectKeysReplacement
 
     , eventEmittterReplacement = [
         /(require\('events'\)\.EventEmitter;)/
@@ -122,7 +117,7 @@ const headRegexp = /(^module.exports = \w+;?)/m
     ]
 
     , isBufferReplacement = [
-      /(\w+) instanceof Buffer/
+      /(\w+) instanceof Buffer/g
     , 'Buffer.isBuffer($1)'
     ]
 
@@ -202,6 +197,7 @@ module.exports['_stream_writable.js'] = [
   , debugLogReplacement
   , deprecateReplacement
   , objectDefinePropertyReplacement
+  , objectDefinePropertySingReplacement
   , bufferIsEncodingReplacement
   , [ /^var assert = require\('assert'\);$/m, '' ]
   , requireStreamReplacement

build/test-replacements.js

@@ -2,6 +2,10 @@ const altForEachImplReplacement = require('./common-replacements').altForEachImp
     , altForEachUseReplacement  = require('./common-replacements').altForEachUseReplacement
     , altIndexOfImplReplacement = require('./common-replacements').altIndexOfImplReplacement
     , altIndexOfUseReplacement  = require('./common-replacements').altIndexOfUseReplacement
+    , objectKeysDefine =
+    require('./common-replacements').objectKeysDefine
+    , objectKeysReplacement =
+    require('./common-replacements').objectKeysReplacement
 
 module.exports.all = [
     [
@@ -55,7 +59,9 @@ module.exports['test-stream-big-packet.js'] = [
 ]
 
 module.exports['common.js'] = [
-    altForEachImplReplacement
+    objectKeysDefine
+  , objectKeysReplacement
+  , altForEachImplReplacement
   , altForEachUseReplacement
 
   , [
@@ -106,6 +112,18 @@ module.exports['common.js'] = [
         + '}\n'
         + '/*</replacement>*/\n'
     ]
+  , [
+        /^if \(global\.ArrayBuffer\) \{([^\}]+)\}$/m
+      ,   '/*<replacement>*/if (!process.browser) {'
+        + '\nif \(global\.ArrayBuffer\) {$1}\n'
+        + '}/*</replacement>*/\n'
+    ]
+    , [
+          /^Object\.defineProperty\(([\w\W]+?)\}\)\;/mg
+        ,   '/*<replacement>*/if (!process.browser) {'
+          + '\nObject\.defineProperty($1});\n'
+          + '}/*</replacement>*/\n'
+      ]
 ]
 
 // this test has some trouble with the nextTick depth when run

lib/_stream_duplex.js

@@ -5,13 +5,6 @@
 
 'use strict';
 
-module.exports = Duplex;
-
-/*<replacement>*/
-var processNextTick = require('process-nextick-args');
-/*</replacement>*/
-
-
 /*<replacement>*/
 var objectKeys = Object.keys || function (obj) {
   var keys = [];
@@ -21,6 +14,13 @@ var objectKeys = Object.keys || function (obj) {
 /*</replacement>*/
 
 
+module.exports = Duplex;
+
+/*<replacement>*/
+var processNextTick = require('process-nextick-args');
+/*</replacement>*/
+
+
 
 /*<replacement>*/
 var util = require('core-util-is');

lib/_stream_writable.js

@@ -143,12 +143,15 @@ WritableState.prototype.getBuffer = function writableStateGetBuffer() {
   return out;
 };
 
+(function (){try {
 Object.defineProperty(WritableState.prototype, 'buffer', {
   get: require('util-deprecate')(function() {
     return this.getBuffer();
   }, '_writableState.buffer is deprecated. Use ' +
       '_writableState.getBuffer() instead.')
 });
+}catch(_){}}());
+
 
 function Writable(options) {
   var Duplex = require('./_stream_duplex');
@@ -217,7 +220,7 @@ Writable.prototype.write = function(chunk, encoding, cb) {
     encoding = null;
   }
 
-  if (chunk instanceof Buffer)
+  if (Buffer.isBuffer(chunk))
     encoding = 'buffer';
   else if (!encoding)
     encoding = state.defaultEncoding;
@@ -282,7 +285,7 @@ function decodeChunk(state, chunk, encoding) {
 function writeOrBuffer(stream, state, chunk, encoding, cb) {
   chunk = decodeChunk(state, chunk, encoding);
 
-  if (chunk instanceof Buffer)
+  if (Buffer.isBuffer(chunk))
     encoding = 'buffer';
   var len = state.objectMode ? 1 : chunk.length;
 

package.json

@@ -5,17 +5,20 @@
   "main": "readable.js",
   "dependencies": {
     "core-util-is": "~1.0.0",
-    "process-nextick-args": "~1.0.0",
     "inherits": "~2.0.1",
     "isarray": "0.0.1",
+    "process-nextick-args": "~1.0.0",
     "string_decoder": "~0.10.x",
     "util-deprecate": "~1.0.1"
   },
   "devDependencies": {
-    "tap": "~0.2.6"
+    "tap": "~0.2.6",
+    "tape": "~4.0.0",
+    "zuul": "~3.0.0"
   },
   "scripts": {
-    "test": "tap test/parallel/*.js"
+    "test": "tap test/parallel/*.js",
+    "browser": "zuul --browser-name $BROWSER_NAME --browser-version $BROWSER_VERSION -- test/browser.js"
   },
   "repository": {
     "type": "git",

test/browser.js

@@ -0,0 +1,61 @@
+if (!global.console) {
+  global.console = {};
+}
+if (!global.console.log) {
+  global.console.log = function () {};
+}
+if (!global.console.error) {
+  global.console.error = global.console.log;
+}
+if (!global.console.info) {
+  global.console.info = global.console.log;
+}
+var test = require('tape');
+
+test('streams', function (t) {
+  require('./browser/test-stream-big-packet')(t);
+  require('./browser/test-stream-big-push')(t);
+  require('./browser/test-stream-duplex')(t);
+  require('./browser/test-stream-end-paused')(t);
+  require('./browser/test-stream-ispaused')(t);
+  require('./browser/test-stream-pipe-after-end')(t);
+  require('./browser/test-stream-pipe-cleanup')(t);
+  require('./browser/test-stream-pipe-error-handling')(t);
+  require('./browser/test-stream-pipe-event')(t);
+  require('./browser/test-stream-push-order')(t);
+  require('./browser/test-stream-push-strings')(t);
+  require('./browser/test-stream-readable-constructor-set-methods')(t);
+  require('./browser/test-stream-readable-event')(t);
+  require('./browser/test-stream-transform-constructor-set-methods')(t);
+  require('./browser/test-stream-transform-objectmode-falsey-value')(t);
+  require('./browser/test-stream-transform-split-objectmode')(t);
+  require('./browser/test-stream-unshift-empty-chunk')(t);
+  require('./browser/test-stream-unshift-read-race')(t);
+  require('./browser/test-stream-writable-change-default-encoding')(t);
+  require('./browser/test-stream-writable-constructor-set-methods')(t);
+  require('./browser/test-stream-writable-decoded-encoding')(t);
+  require('./browser/test-stream-writev')(t);
+});
+
+test('streams 2', function (t) {
+  require('./browser/test-stream2-base64-single-char-read-end')(t);
+  require('./browser/test-stream2-compatibility')(t);
+  require('./browser/test-stream2-large-read-stall')(t);
+  require('./browser/test-stream2-objects')(t);
+  require('./browser/test-stream2-pipe-error-handling')(t);
+  require('./browser/test-stream2-pipe-error-once-listener')(t);
+  require('./browser/test-stream2-push')(t);
+  require('./browser/test-stream2-readable-empty-buffer-no-eof')(t);
+  require('./browser/test-stream2-readable-from-list')(t);
+  require('./browser/test-stream2-transform')(t);
+  require('./browser/test-stream2-set-encoding')(t);
+  require('./browser/test-stream2-readable-legacy-drain')(t);
+  require('./browser/test-stream2-readable-wrap-empty')(t);
+  require('./browser/test-stream2-readable-non-empty-end')(t);
+  require('./browser/test-stream2-readable-wrap')(t);
+  require('./browser/test-stream2-unpipe-drain')(t);
+  require('./browser/test-stream2-writable')(t);
+});
+test('streams 3', function (t) {
+  require('./browser/test-stream3-pause-then-read')(t);
+});