Skip to content

Commit 273a3f9

Browse files
committed
fixed test
1 parent dcbcdd3 commit 273a3f9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/topic/topicreadercommon/message.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,7 @@ func MessageWithSetCommitRangeForTest(m *PublicMessage, commitRange CommitRange)
270270
}
271271

272272
func MessageSetNilDataForTest(m *PublicMessage) {
273-
m.data = newOneTimeReaderFromReader(nil)
273+
m.data = newOneTimeReader(nil)
274274
m.bufferBytesAccount = 0
275275
m.dataConsumed = false
276276
}

0 commit comments

Comments
 (0)