You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: src/core/k8.mjs
+4-6Lines changed: 4 additions & 6 deletions
Original file line number
Diff line number
Diff line change
@@ -579,16 +579,15 @@ export class K8 {
579
579
letadditionalErrorMessageDetail=''
580
580
581
581
// Use pipe() to automatically handle backpressure between streams
582
-
outputPassthroughStream.pipe(outputFileStream);
582
+
outputPassthroughStream.pipe(outputFileStream)
583
583
584
584
outputPassthroughStream.on('data',(chunk)=>{
585
-
constcanWrite=outputFileStream.write(chunk);// Write chunk to file and check if buffer is full
585
+
constcanWrite=outputFileStream.write(chunk)// Write chunk to file and check if buffer is full
586
586
587
587
if(!canWrite){
588
-
console.log(`Buffer is full, pausing data stream... for copying from ${podName}:${srcDir}/${srcFile} to ${destPath}`);
589
-
outputPassthroughStream.pause();// Pause the data stream if buffer is full
588
+
console.log(`Buffer is full, pausing data stream... for copying from ${podName}:${srcDir}/${srcFile} to ${destPath}`)
589
+
outputPassthroughStream.pause()// Pause the data stream if buffer is full
590
590
}
591
-
592
591
})
593
592
594
593
outputFileStream.on('drain',()=>{
@@ -663,7 +662,6 @@ export class K8 {
663
662
664
663
outputFileStream.on('error',(err)=>{
665
664
returnreject(newFullstackTestingError(`writerStream error encountered copying from ${podName}:${srcDir}/${srcFile} to ${destPath}, err: ${err.toString()}`,err))
0 commit comments