Fix previous commit

flanglet · Jan 20, 2024 · 96813f9 · 96813f9
1 parent eb02406
commit 96813f9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/v2/io/CompressedStream.go b/v2/io/CompressedStream.go
@@ -1441,7 +1441,7 @@ func (this *decodingTask) decode(res *decodingTaskResult) {
 	}()
 
 	// Lock free synchronization
-	for {
+	for n := 0; ; n++ {
 		taskID := atomic.LoadInt32(this.processedBlockID)
 
 		if taskID == _CANCEL_TASKS_ID {

diff --git a/v2/io/CompressedStream_test.go b/v2/io/CompressedStream_test.go
@@ -32,7 +32,7 @@ func TestCompressedStream(b *testing.T) {
 
 	for test := 1; test <= 20; test++ {
 		length := 65536 << uint(test%7)
-		fmt.Printf("\nIteration %v)\n", test)
+		fmt.Printf("\nIteration %v\n", test)
 
 		for i := range values {
 			values[i] = byte(rand.Intn(4*test + 1))