diff --git a/csv.go b/csv.go index 3225997..c76a14d 100644 --- a/csv.go +++ b/csv.go @@ -96,6 +96,7 @@ func (c *Converter) rowToCSV(toCSV chan []string, toGzip chan *csvBuf, wg *sync. data: csvBuffer.Bytes(), lastPart: true, } + fmt.Println(string(csvBuffer.Bytes())) // Reset buffer csvBuffer.Reset() diff --git a/gzip.go b/gzip.go index 13be031..0d6198f 100644 --- a/gzip.go +++ b/gzip.go @@ -46,6 +46,8 @@ func (c *Converter) csvToGzip(toGzip chan *csvBuf, w io.Writer, wg *sync.WaitGro return } + fmt.Println(string(csvBuf.data)) + if csvBuf.lastPart { err = zw.Close() if err != nil {