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.
2 parents c78681e + f9b4124 commit 846b6edCopy full SHA for 846b6ed
internal/topic/topicreadercommon/message.go
@@ -66,6 +66,9 @@ func (m *PublicMessage) UnmarshalTo(dst PublicMessageContentUnmarshaler) error {
66
// Read implements io.Reader
67
// Read uncompressed message content
68
// return topicreader.UnexpectedCodec if message compressed with unknown codec
69
+//
70
+// Content of the message released from the memory after first read error
71
+// including io.EOF.
72
func (m *PublicMessage) Read(p []byte) (n int, err error) {
73
m.dataConsumed = true
74
0 commit comments