Ensure inner output stream will be closed

Author: zhicwu

clickhouse-client/src/main/java/com/clickhouse/client/stream/Lz4OutputStream.java

@@ -82,4 +82,16 @@ public void flush() throws IOException {
         }
         output.flush();
     }
+
+    @Override
+    public void close() throws IOException {
+        if (!closed) {
+            try {
+                // flush before closing the inner output stream
+                super.close();
+            } finally {
+                output.close();
+            }
+        }
+    }
 }

clickhouse-client/src/main/java/com/clickhouse/client/stream/WrappedOutputStream.java

@@ -36,4 +36,16 @@ public void flush() throws IOException {
         }
         output.flush();
     }
+
+    @Override
+    public void close() throws IOException {
+        if (!closed) {
+            try {
+                // flush before closing the inner output stream
+                super.close();
+            } finally {
+                output.close();
+            }
+        }
+    }
 }