summaryrefslogtreecommitdiff
path: root/lib/_stream_readable.js
diff options
context:
space:
mode:
authorRuben Bridgewater <ruben@bridgewater.de>2019-03-07 01:03:53 +0100
committerRuben Bridgewater <ruben@bridgewater.de>2019-03-10 00:44:40 +0100
commitf8763bb077db2f0be74e353c0b4f9e353c0fffa8 (patch)
treec73128074daa65d2e72e4d2a86a5b08059888144 /lib/_stream_readable.js
parent01a5300f3f4f788a043f6b5fe72e2b7b641dfb6c (diff)
downloadandroid-node-v8-f8763bb077db2f0be74e353c0b4f9e353c0fffa8.tar.gz
android-node-v8-f8763bb077db2f0be74e353c0b4f9e353c0fffa8.tar.bz2
android-node-v8-f8763bb077db2f0be74e353c0b4f9e353c0fffa8.zip
benchmark,doc,lib,test: capitalize comments
PR-URL: https://github.com/nodejs/node/pull/26483 Reviewed-By: Vse Mozhet Byt <vsemozhetbyt@gmail.com> Reviewed-By: Michaƫl Zasso <targos@protonmail.com>
Diffstat (limited to 'lib/_stream_readable.js')
-rw-r--r--lib/_stream_readable.js16
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index 957f232b63..968c7b258c 100644
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -190,7 +190,7 @@ Object.defineProperty(Readable.prototype, 'destroyed', {
return this._readableState.destroyed;
},
set(value) {
- // we ignore the value if the stream
+ // We ignore the value if the stream
// has not been initialized yet
if (!this._readableState) {
return;
@@ -600,7 +600,7 @@ function maybeReadMore_(stream, state) {
debug('maybeReadMore read 0');
stream.read(0);
if (len === state.length)
- // didn't get any data, stop spinning.
+ // Didn't get any data, stop spinning.
break;
}
state.readingMore = false;
@@ -741,7 +741,7 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
src.unpipe(dest);
}
- // tell the dest that it's being piped to
+ // Tell the dest that it's being piped to
dest.emit('pipe', src);
// Start the flow if it hasn't been started already.
@@ -793,7 +793,7 @@ Readable.prototype.unpipe = function(dest) {
return this;
}
- // slow case. multiple pipe destinations.
+ // Slow case with multiple pipe destinations.
if (!dest) {
// remove all.
@@ -896,7 +896,7 @@ function updateReadableListening(self) {
// the upcoming resume will not flow.
state.flowing = true;
- // crude way to check if we should resume
+ // Crude way to check if we should resume
} else if (self.listenerCount('data') > 0) {
self.resume();
}
@@ -1008,7 +1008,7 @@ Readable.prototype.wrap = function(stream) {
}
}
- // proxy certain important events.
+ // Proxy certain important events.
for (var n = 0; n < kProxyEvents.length; n++) {
stream.on(kProxyEvents[n], this.emit.bind(this, kProxyEvents[n]));
}
@@ -1070,7 +1070,7 @@ Object.defineProperty(Readable.prototype, 'readableFlowing', {
}
});
-// exposed for testing purposes only.
+// Exposed for testing purposes only.
Readable._fromList = fromList;
Object.defineProperty(Readable.prototype, 'readableLength', {
@@ -1096,7 +1096,7 @@ function fromList(n, state) {
if (state.objectMode)
ret = state.buffer.shift();
else if (!n || n >= state.length) {
- // read it all, truncate the list
+ // Read it all, truncate the list
if (state.decoder)
ret = state.buffer.join('');
else if (state.buffer.length === 1)