| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -13,6 +13,8 @@ var StringDecoder; | |||
| 13 | 13 | ||
| 14 | 14 | util.inherits(Readable, Stream); | |
| 15 | 15 | ||
| 16 | + const kProxyEvents = ['error', 'close', 'destroy', 'pause', 'resume']; | ||
| 17 | + | ||
| 16 | 18 | function prependListener(emitter, event, fn) { | |
| 17 | 19 | // Sadly this is not cacheable as some libraries bundle their own | |
| 18 | 20 | // event emitter implementation with them. | |
@@ -811,10 +813,9 @@ Readable.prototype.wrap = function(stream) { | |||
| 811 | 813 | } | |
| 812 | 814 | ||
| 813 | 815 | // proxy certain important events. | |
| 814 | - const events = ['error', 'close', 'destroy', 'pause', 'resume']; | ||
| 815 | - events.forEach(function(ev) { | ||
| 816 | - stream.on(ev, self.emit.bind(self, ev)); | ||
| 817 | - }); | ||
| 816 | + for (var n = 0; n < kProxyEvents.length; n++) { | ||
| 817 | + stream.on(kProxyEvents[n], self.emit.bind(self, kProxyEvents[n])); | ||
| 818 | + } | ||
| 818 | 819 | ||
| 819 | 820 | // when we try to consume some more bytes, simply unpause the | |
| 820 | 821 | // underlying stream. | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -118,9 +118,8 @@ StreamWrap.prototype.doWrite = function doWrite(req, bufs) { | |||
| 118 | 118 | const item = self._enqueue('write', req); | |
| 119 | 119 | ||
| 120 | 120 | self.stream.cork(); | |
| 121 | - bufs.forEach(function(buf) { | ||
| 122 | - self.stream.write(buf, done); | ||
| 123 | - }); | ||
| 121 | + for (var n = 0; n < bufs.length; n++) | ||
| 122 | + self.stream.write(bufs[n], done); | ||
| 124 | 123 | self.stream.uncork(); | |
| 125 | 124 | ||
| 126 | 125 | function done(err) { | |
| Back | FazBrowse Home | New Git URL |
0 commit comments