Merge pull request #943 from kubernetes-client/patch-2

Close the writestream before heading over to untar also read failure from status.

Author: k8s-ci-robot

src/cp.ts

@@ -40,8 +40,9 @@ export class Cp {
             errStream,
             null,
             false,
-            async () => {
-                if (errStream.size()) {
+            async ({ status }) => {
+                writerStream.close();
+                if (status === 'Failure' || errStream.size()) {
                     throw new Error(`Error from cpFromPod - details: \n ${errStream.getContentsAsString()}`);
                 }
                 await tar.x({
@@ -86,8 +87,8 @@ export class Cp {
             errStream,
             readStream,
             false,
-            async () => {
-                if (errStream.size()) {
+            async ({ status }) => {
+                if (status === 'Failure' || errStream.size()) {
                     throw new Error(`Error from cpToPod - details: \n ${errStream.getContentsAsString()}`);
                 }
             },