add Flush() method

stokito · Feb 21, 2023 · bf3a786 · bf3a786
1 parent 4c8f03c
commit bf3a786
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/gzip_buf_file.go b/gzip_buf_file.go
@@ -60,9 +60,13 @@ func (f *GzBufFile) WriteTwoLines(line1 []byte, line2 []byte) error {
 }
 
 func (f *GzBufFile) Close() error {
-	_ = f.bufWriter.Flush()
-	_ = f.gzipWriter.Flush()
+	_ = f.Flush()
 	// Close the gzip first.
 	_ = f.gzipWriter.Close()
 	return f.outputFile.Close()
 }
+
+func (f *GzBufFile) Flush() error {
+	_ = f.bufWriter.Flush()
+	return f.gzipWriter.Flush()
+}