From 6d6ef22134f4b23753b8a5894311a73099f79510 Mon Sep 17 00:00:00 2001
From: Jay <wisehodl@pm.me>
Date: Sun, 17 May 2026 12:14:11 -0400
Subject: [PATCH] stream: registers but does not spawn session when
 disconnected

---
 request_test.go | 26 ++++++++++++++++++++++----
 1 file changed, 22 insertions(+), 4 deletions(-)

diff --git a/request_test.go b/request_test.go
index 9e97590..1a814e1 100644
--- a/request_test.go
+++ b/request_test.go
@@ -239,10 +239,28 @@ func TestRequestManager_Stream(t *testing.T) {
 	})
 
 	t.Run("registers but does not spawn session when disconnected", func(t *testing.T) {
-		// do not connect the envoy
-		// call Stream
-		// assert mock send is never called
-		// assert the returned channels are non-nil and open
+		p := newMockPool(t)
+		emb := NewEmbassy(p.ctx, p.plugin, nil)
+		err := emb.Dispatch(p.url)
+		assert.NoError(t, err)
+		envoy := emb.Call(p.url)
+
+		m := NewRequestManager(envoy)
+		filters := [][]byte{[]byte(`{}`)}
+		id, events, closed := m.Stream(filters)
+
+		assert.NotEmpty(t, id)
+		assert.NotNil(t, events)
+		assert.NotNil(t, closed)
+
+		Never(t, func() bool {
+			select {
+			case <-p.sent:
+				return true
+			default:
+				return false
+			}
+		}, "send should not be called when disconnected")
 	})
 
 	t.Run("forwards events to caller", func(t *testing.T) {