clean up stream handling for file copy
This commit is contained in:
@@ -75,8 +75,9 @@ module.exports = UrlCache =
|
|||||||
readStream = fs.createReadStream(from)
|
readStream = fs.createReadStream(from)
|
||||||
writeStream.on "error", callbackOnce
|
writeStream.on "error", callbackOnce
|
||||||
readStream.on "error", callbackOnce
|
readStream.on "error", callbackOnce
|
||||||
writeStream.on "close", () -> callbackOnce()
|
writeStream.on "close", callbackOnce
|
||||||
readStream.pipe(writeStream)
|
writeStream.on "open", () ->
|
||||||
|
readStream.pipe(writeStream)
|
||||||
|
|
||||||
_clearUrlFromCache: (project_id, url, callback = (error) ->) ->
|
_clearUrlFromCache: (project_id, url, callback = (error) ->) ->
|
||||||
UrlCache._clearUrlDetails project_id, url, (error) ->
|
UrlCache._clearUrlDetails project_id, url, (error) ->
|
||||||
|
|||||||
Reference in New Issue
Block a user