Skip to content

Commit

Permalink
use a browser sub for the streams vs event emitter switch
Browse files Browse the repository at this point in the history
  • Loading branch information
calvinmetcalf authored and mcollina committed Apr 8, 2017
1 parent c951fba commit be98a01
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 18 deletions.
1 change: 1 addition & 0 deletions _internal_stream-browser.js
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
module.exports = require('events').EventEmitter;
1 change: 1 addition & 0 deletions _internal_stream.js
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
module.exports = require('stream');
6 changes: 1 addition & 5 deletions build/files.js
Original file line number Diff line number Diff line change
Expand Up @@ -111,11 +111,7 @@ const headRegexp = /(^module.exports = \w+;?)/m
, requireStreamReplacement = [
/const Stream = require\('stream'\);/
, '\n\n/*<replacement>*/\n'
+ 'var Stream;\nif (process.browser){\n'
+ ' Stream = require(\'events\').EventEmitter;\n'
+ '} else {\n'
+ ' Stream = require(\'st\' + \'ream\');\n'
+ '}'
+ 'var Stream = require(\'../_internal_stream\')'
+ '\n/*</replacement>*/\n'
]

Expand Down
7 changes: 1 addition & 6 deletions lib/_stream_readable.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ var EElistenerCount = function (emitter, type) {
/*</replacement>*/

/*<replacement>*/
var Stream;
if (process.browser) {
Stream = require('events').EventEmitter;
} else {
Stream = require('st' + 'ream');
}
var Stream = require('../_internal_stream');
/*</replacement>*/

var Buffer = require('buffer').Buffer;
Expand Down
7 changes: 1 addition & 6 deletions lib/_stream_writable.js
Original file line number Diff line number Diff line change
Expand Up @@ -32,12 +32,7 @@ var internalUtil = {
/*</replacement>*/

/*<replacement>*/
var Stream;
if (process.browser) {
Stream = require('events').EventEmitter;
} else {
Stream = require('st' + 'ream');
}
var Stream = require('../_internal_stream');
/*</replacement>*/

var Buffer = require('buffer').Buffer;
Expand Down
3 changes: 2 additions & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,8 @@
"util": false,
"./readable.js": "./readable-browser.js",
"./writable.js": "./writable-browser.js",
"./duplex.js": "./duplex-browser.js"
"./duplex.js": "./duplex-browser.js",
"./_internal_stream.js": "./_internal_stream-browser.js"
},
"react-native": {
"stream": false
Expand Down

0 comments on commit be98a01

Please sign in to comment.