Static files stream fix

piliugin-anton · piliugin-anton · commit b6164138f7c2 · 2022-07-18T03:37:25.000+05:00
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "uquik",
-  "version": "1.0.46",
+  "version": "1.0.47",
   "description": "uQuik HTTP(S) framework",
   "main": "index.js",
   "scripts": {
diff --git a/src/StaticFiles.js b/src/StaticFiles.js
@@ -131,7 +131,7 @@ const StaticFiles = (options = {}) => {
 
         dataTransfer.transform.once('end', () => !dataTransfer.transform.destroyed && dataTransfer.transform.destroy())
 
-        pipeline(dataTransfer.readable, dataTransfer.transform, res, (error) => res.throw(error))
+        pipeline(dataTransfer.readable, dataTransfer.transform, res, () => destroy(dataTransfer))
       } else {
         res.stream(dataTransfer.readable, size)
       }

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "uquik",`
`3`		`- "version": "1.0.46",`
	`3`	`+ "version": "1.0.47",`
`4`	`4`	`"description": "uQuik HTTP(S) framework",`
`5`	`5`	`"main": "index.js",`
`6`	`6`	`"scripts": {`
Original file line number	Diff line number	Diff line change
`@@ -131,7 +131,7 @@ const StaticFiles = (options = {}) => {`
`131`	`131`
`132`	`132`	`dataTransfer.transform.once('end', () => !dataTransfer.transform.destroyed && dataTransfer.transform.destroy())`
`133`	`133`
`134`		`- pipeline(dataTransfer.readable, dataTransfer.transform, res, (error) => res.throw(error))`
	`134`	`+ pipeline(dataTransfer.readable, dataTransfer.transform, res, () => destroy(dataTransfer))`
`135`	`135`	`} else {`
`136`	`136`	`res.stream(dataTransfer.readable, size)`
`137`	`137`	`}`