From d5261c7e4600e0d4fecf565f76b85bf393e0be70 Mon Sep 17 00:00:00 2001
From: Jay <wisehodl@pm.me>
Date: Sun, 17 May 2026 16:00:11 -0400
Subject: [PATCH] test: add cleanup to manager tests to prevent goroutine leaks

---
 request_test.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/request_test.go b/request_test.go
index 11d4f47..5162d65 100644
--- a/request_test.go
+++ b/request_test.go
@@ -214,6 +214,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, closed := m.Stream(filters)
 
@@ -238,6 +239,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		p, envoy := newMockEnvoy(t)
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, closed := m.Stream(filters)
 
@@ -261,6 +263,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, _ := m.Stream(filters)
 
@@ -304,6 +307,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, closed := m.Stream(filters)
 
@@ -355,6 +359,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, closed := m.Stream(filters)
 
@@ -411,6 +416,7 @@ func TestRequestManager_Stream(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, _, _ := m.Stream(filters)
 
@@ -446,6 +452,7 @@ func TestRequestManager_Cancel(t *testing.T) {
 		Eventually(t, envoy.IsConnected, "envoy should be connected")
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, _ := m.Stream(filters)
 
@@ -500,6 +507,7 @@ func TestRequestManager_Cancel(t *testing.T) {
 		// do not connect — no session will be spawned
 
 		m := NewRequestManager(envoy)
+		t.Cleanup(func() { m.Close() })
 		filters := [][]byte{[]byte(`{}`)}
 		id, events, _ := m.Stream(filters)