ignore broken pipe in stdout commands

Author: MichaelKim0407

stream/io/ftp.py

@@ -272,7 +272,7 @@ def download_cmd():
 
 def get_cmd():
     import argparse
-    from stream.io.std import StdOut
+    from stream.io.std import StdOut, stderr
     parser = argparse.ArgumentParser()
     parser.add_argument('url', type=str, nargs='?')
     parser.add_argument('--host', '-H', type=str)
@@ -290,4 +290,8 @@ def get_cmd():
             path,
     ) as f:
         with StdOut() as stdout:
-            f.dump_to_buffer(stdout.buffer)
+            try:
+                f.dump_to_buffer(stdout.buffer)
+            except BrokenPipeError:
+                # avoid "exception ignored" message
+                stderr.close()

stream/io/http.py

@@ -126,11 +126,15 @@ def download_cmd():
 
 def get_cmd():
     import argparse
-    from stream.io.std import StdOut
+    from stream.io.std import StdOut, stderr
     parser = argparse.ArgumentParser()
     parser.add_argument('url', type=str)
     args = parser.parse_args()
 
     with HttpDownloadFile(args.url) as f:
         with StdOut() as stdout:
-            f.copy_to(stdout.buffer)
+            try:
+                f.copy_to(stdout.buffer)
+            except BrokenPipeError:
+                # avoid "exception ignored" message
+                stderr.close()

stream/io/s3.py

@@ -355,7 +355,7 @@ def get_cmd():
     Stream to stdout
     """
     import argparse
-    from stream.io.std import StdOut
+    from stream.io.std import StdOut, stderr
     parser = argparse.ArgumentParser()
     parser.add_argument('bucket')
     parser.add_argument('key')
@@ -367,7 +367,11 @@ def get_cmd():
             lines=False,
     ) as f:
         with StdOut() as stdout:
-            f.copy_to(stdout.buffer)
+            try:
+                f.copy_to(stdout.buffer)
+            except BrokenPipeError:
+                # avoid "exception ignored" message
+                stderr.close()
 
 
 def copy_cmd():