We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c78183f commit 2f0fdedCopy full SHA for 2f0fded
internal/topic/topicreaderinternal/reader_test.go
@@ -69,7 +69,11 @@ func TestReader_Close(t *testing.T) {
69
readerReadMessageBatchState := newCallState()
70
71
go func() {
72
- readerCommitState.err = reader.Commit(context.Background(), &PublicMessage{})
+ readerCommitState.err = reader.Commit(context.Background(), &PublicMessage{
73
+ commitRange: commitRange{
74
+ partitionSession: &partitionSession{},
75
+ },
76
+ })
77
close(readerCommitState.callCompleted)
78
}()
79
0 commit comments