maxmustermann/kibana
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Bump end-of-stream from v1.4.1 to v1.4.4 (#76479)

Browse source
This commit is contained in:
Thomas Watson 2020-09-02 20:45:52 +02:00 committed by GitHub
parent de3ddbc6e1
commit b8822da21e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
packages/kbn-pm/dist/index.js vendored
View file

@ -27651,6 +27651,7 @@ var eos = function(stream, opts, callback) {
var rs = stream._readableState; var rs = stream._readableState;
var readable = opts.readable || (opts.readable !== false && stream.readable); var readable = opts.readable || (opts.readable !== false && stream.readable);
var writable = opts.writable || (opts.writable !== false && stream.writable); var writable = opts.writable || (opts.writable !== false && stream.writable);
var cancelled = false;
var onlegacyfinish = function() { var onlegacyfinish = function() {
if (!stream.writable) onfinish(); if (!stream.writable) onfinish();
@ -27675,8 +27676,13 @@ var eos = function(stream, opts, callback) {
}; };
var onclose = function() { var onclose = function() {
if (readable && !(rs && rs.ended)) return callback.call(stream, new Error('premature close')); process.nextTick(onclosenexttick);
if (writable && !(ws && ws.ended)) return callback.call(stream, new Error('premature close')); };
var onclosenexttick = function() {
if (cancelled) return;
if (readable && !(rs && (rs.ended && !rs.destroyed))) return callback.call(stream, new Error('premature close'));
if (writable && !(ws && (ws.ended && !ws.destroyed))) return callback.call(stream, new Error('premature close'));
}; };
var onrequest = function() { var onrequest = function() {
@ -27701,6 +27707,7 @@ var eos = function(stream, opts, callback) {
stream.on('close', onclose); stream.on('close', onclose);
return function() { return function() {
cancelled = true;
stream.removeListener('complete', onfinish); stream.removeListener('complete', onfinish);
stream.removeListener('abort', onclose); stream.removeListener('abort', onclose);
stream.removeListener('request', onrequest); stream.removeListener('request', onrequest);

9
yarn.lock
View file

@ -11392,14 +11392,7 @@ encoding@^0.1.11:
dependencies: dependencies:
iconv-lite "~0.4.13" iconv-lite "~0.4.13"
end-of-stream@^1.0.0, end-of-stream@^1.1.0: end-of-stream@^1.0.0, end-of-stream@^1.1.0, end-of-stream@^1.4.1, end-of-stream@^1.4.4:
version "1.4.1"
resolved "https://registry.yarnpkg.com/end-of-stream/-/end-of-stream-1.4.1.tgz#ed29634d19baba463b6ce6b80a37213eab71ec43"
integrity sha512-1MkrZNvWTKCaigbn+W15elq2BB/L22nqrSY5DKlo3X6+vclJm8Bb5djXJBmEX6fS3+zCh/F4VBK5Z2KxJt4s2Q==
dependencies:
once "^1.4.0"
end-of-stream@^1.4.1, end-of-stream@^1.4.4:
version "1.4.4" version "1.4.4"
resolved "https://registry.yarnpkg.com/end-of-stream/-/end-of-stream-1.4.4.tgz#5ae64a5f45057baf3626ec14da0ca5e4b2431eb0" resolved "https://registry.yarnpkg.com/end-of-stream/-/end-of-stream-1.4.4.tgz#5ae64a5f45057baf3626ec14da0ca5e4b2431eb0"
integrity sha512-+uw1inIHVPQoaVuHzRyXd21icM+cnt4CzD5rW+NC1wjOUSTOs+Te7FOv7AhN7vS9x/oIyhLP5PR1H+phQAHu5Q== integrity sha512-+uw1inIHVPQoaVuHzRyXd21icM+cnt4CzD5rW+NC1wjOUSTOs+Te7FOv7AhN7vS9x/oIyhLP5PR1H+phQAHu5Q==