diff --git a/internal/compressions/writer_gzip_test.go b/internal/compressions/writer_gzip_test.go index e805e42..71bc90f 100644 --- a/internal/compressions/writer_gzip_test.go +++ b/internal/compressions/writer_gzip_test.go @@ -34,3 +34,31 @@ func BenchmarkGzipWriter_Write(b *testing.B) { _ = writer.Close() } } + +func BenchmarkGzipWriter_Write_Parallel(b *testing.B) { + var data = []byte(strings.Repeat("A", 1024)) + + b.RunParallel(func(pb *testing.PB) { + for pb.Next() { + var buf = &bytes.Buffer{} + writer, err := compressions.NewGzipWriter(buf, 5) + if err != nil { + b.Fatal(err) + } + + for j := 0; j < 100; j++ { + _, err = writer.Write(data) + if err != nil { + b.Fatal(err) + } + + /**err = writer.Flush() + if err != nil { + b.Fatal(err) + }**/ + } + + _ = writer.Close() + } + }) +}