Added missing changes and modified dist assets.
This commit is contained in:
parent
faedee1163
commit
28cf22057f
14
dist/index.js
generated
vendored
14
dist/index.js
generated
vendored
@ -34457,6 +34457,10 @@ class StreamHandler extends AsyncResource {
|
||||
{ callback, body: res, contentType, statusCode, statusMessage, headers }
|
||||
)
|
||||
} else {
|
||||
if (factory === null) {
|
||||
return
|
||||
}
|
||||
|
||||
res = this.runInAsyncScope(factory, null, {
|
||||
statusCode,
|
||||
headers,
|
||||
@ -34505,7 +34509,7 @@ class StreamHandler extends AsyncResource {
|
||||
onData (chunk) {
|
||||
const { res } = this
|
||||
|
||||
return res.write(chunk)
|
||||
return res ? res.write(chunk) : true
|
||||
}
|
||||
|
||||
onComplete (trailers) {
|
||||
@ -34513,6 +34517,10 @@ class StreamHandler extends AsyncResource {
|
||||
|
||||
removeSignal(this)
|
||||
|
||||
if (!res) {
|
||||
return
|
||||
}
|
||||
|
||||
this.trailers = util.parseHeaders(trailers)
|
||||
|
||||
res.end()
|
||||
@ -34969,7 +34977,7 @@ function consumeEnd (consume) {
|
||||
pos += buf.byteLength
|
||||
}
|
||||
|
||||
resolve(dst)
|
||||
resolve(dst.buffer)
|
||||
} else if (type === 'blob') {
|
||||
if (!Blob) {
|
||||
Blob = (__nccwpck_require__(4300).Blob)
|
||||
@ -37405,8 +37413,10 @@ function onParserTimeout (parser) {
|
||||
|
||||
function onSocketReadable () {
|
||||
const { [kParser]: parser } = this
|
||||
if (parser) {
|
||||
parser.readMore()
|
||||
}
|
||||
}
|
||||
|
||||
function onSocketError (err) {
|
||||
const { [kClient]: client, [kParser]: parser } = this
|
||||
|
2
dist/index.js.map
generated
vendored
2
dist/index.js.map
generated
vendored
File diff suppressed because one or more lines are too long
Loading…
x
Reference in New Issue
Block a user