summaryrefslogtreecommitdiff
path: root/lib/_stream_writable.js
diff options
context:
space:
mode:
authorRich Trott <rtrott@gmail.com>2019-11-27 22:56:21 -0800
committerRich Trott <rtrott@gmail.com>2019-11-30 06:28:29 -0800
commit359766b2c3f686fe4ebe5cd6bc4e99280e09b450 (patch)
tree7b62141573f19ce6f1e82392f12732cabda30710 /lib/_stream_writable.js
parent2070d3f8eb14ca9cc5c2e23824b20d700d7183be (diff)
downloadandroid-node-v8-359766b2c3f686fe4ebe5cd6bc4e99280e09b450.tar.gz
android-node-v8-359766b2c3f686fe4ebe5cd6bc4e99280e09b450.tar.bz2
android-node-v8-359766b2c3f686fe4ebe5cd6bc4e99280e09b450.zip
benchmark,doc,lib,test: prepare for padding lint rule
Upcoming lint rule will require a blank line between consecutive functions. Add it in the places where we don't have it already. PR-URL: https://github.com/nodejs/node/pull/30696 Reviewed-By: Michaƫl Zasso <targos@protonmail.com> Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com> Reviewed-By: Gus Caplan <me@gus.host> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Richard Lau <riclau@uk.ibm.com> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Denys Otrishko <shishugi@gmail.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Diffstat (limited to 'lib/_stream_writable.js')
-rw-r--r--lib/_stream_writable.js3
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/_stream_writable.js b/lib/_stream_writable.js
index be83320550..cf498e7d93 100644
--- a/lib/_stream_writable.js
+++ b/lib/_stream_writable.js
@@ -646,6 +646,7 @@ function needFinish(state) {
!state.finished &&
!state.writing);
}
+
function callFinal(stream, state) {
stream._final((err) => {
state.pendingcb--;
@@ -658,6 +659,7 @@ function callFinal(stream, state) {
}
});
}
+
function prefinish(stream, state) {
if (!state.prefinished && !state.finalCalled) {
if (typeof stream._final === 'function' && !state.destroyed) {
@@ -736,6 +738,7 @@ function onFinished(stream, state, cb) {
stream.emit('error', err);
}
}
+
function onfinish() {
stream.removeListener('finish', onfinish);
stream.removeListener('error', onerror);