test(grok): check filter body close error

This commit is contained in:
wucm667 committed 2026-07-31 18:34:11 +08:00
1 parent baaae8e121
commit 77d4df9544
1 file changed
+1 -1
@@ -205,7 +205,7 @@ func TestGrokResponsesBillingPingFilterCloseCancelsSourceOnce(t *testing.T) {
func TestGrokResponsesBillingPingFilterFlushesCompletedFrames(t *testing.T) {
upstreamReader, upstreamWriter := io.Pipe()
body := newGrokResponsesBillingPingFilterBody(upstreamReader, &Account{Platform: PlatformGrok}, defaultMaxLineSize)
defer body.Close()
t.Cleanup(func() { require.NoError(t, body.Close()) })
go func() {
_, _ = io.WriteString(upstreamWriter, "event: future.event\ndata: {\"type\":\"future.event\"}\n\n")