address comment

coderzc · coderzc · commit 490eb9e814fd · 2025-11-11T17:12:32.000+08:00
diff --git a/pulsar/internal/commands_test.go b/pulsar/internal/commands_test.go
@@ -98,8 +98,9 @@ func TestReadMessageOldFormat(t *testing.T) {
 	assert.Equal(t, true, ssm == nil)
 	assert.Equal(t, "hello", string(payload))
 
-	_, payload, _ = reader.ReadMessage()
+	_, payload, err = reader.ReadMessage()
 	assert.Equal(t, []byte{}, payload)
+	assert.Nil(t, err)
 }
 
 func TestReadMessagesBatchSize1(t *testing.T) {

Original file line number	Diff line number	Diff line change
`@@ -98,8 +98,9 @@ func TestReadMessageOldFormat(t *testing.T) {`
`98`	`98`	`assert.Equal(t, true, ssm == nil)`
`99`	`99`	`assert.Equal(t, "hello", string(payload))`
`100`	`100`
`101`		`- _, payload, _ = reader.ReadMessage()`
	`101`	`+ _, payload, err = reader.ReadMessage()`
`102`	`102`	`assert.Equal(t, []byte{}, payload)`
	`103`	`+ assert.Nil(t, err)`
`103`	`104`	`}`
`104`	`105`
`105`	`106`	`func TestReadMessagesBatchSize1(t *testing.T) {`