Skip to content

Commit d5d9116

Browse files
authored
initialize joined channel in Generation (#828)
1 parent 382e96d commit d5d9116

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

reader_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1295,6 +1295,7 @@ func TestCommitLoopImmediateFlushOnGenerationEnd(t *testing.T) {
12951295
done: make(chan struct{}),
12961296
log: func(func(Logger)) {},
12971297
logError: func(func(Logger)) {},
1298+
joined: make(chan struct{}),
12981299
}
12991300

13001301
// initialize commits so that the commitLoopImmediate select statement blocks

0 commit comments

Comments
 (0)