initialize joined channel in Generation (segmentio#828)

jiujuan · Jan 21, 2022 · d5d9116 · d5d9116
1 parent 382e96d
commit d5d9116
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/reader_test.go b/reader_test.go
@@ -1295,6 +1295,7 @@ func TestCommitLoopImmediateFlushOnGenerationEnd(t *testing.T) {
 		done:     make(chan struct{}),
 		log:      func(func(Logger)) {},
 		logError: func(func(Logger)) {},
+		joined:   make(chan struct{}),
 	}
 
 	// initialize commits so that the commitLoopImmediate select statement blocks