fix test

coderzc · coderzc · commit 0a18a00bb3f5 · 2025-11-04T21:25:33.000+08:00
diff --git a/pulsar/internal/commands_test.go b/pulsar/internal/commands_test.go
@@ -98,8 +98,8 @@ func TestReadMessageOldFormat(t *testing.T) {
 	assert.Equal(t, true, ssm == nil)
 	assert.Equal(t, "hello", string(payload))
 
-	_, _, err = reader.ReadMessage()
-	assert.Equal(t, ErrEOM, err)
+	_, payload, err = reader.ReadMessage()
+	assert.Equal(t, []byte{}, payload)
 }
 
 func TestReadMessagesBatchSize1(t *testing.T) {

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