diff --git a/request_test.go b/request_test.go index 05c031f..537fa7a 100644 --- a/request_test.go +++ b/request_test.go @@ -605,42 +605,6 @@ func TestRequestManager_Reconnect(t *testing.T) { }) } -func TestRequestManager_InboxRouting(t *testing.T) { - t.Run("routes event to correct request buffer", func(t *testing.T) { - // connect, open two streams (sub ids A and B) - // inject an EVENT addressed to sub id A - // assert A's events channel receives the message - // assert B's events channel receives nothing - }) - - t.Run("drops event for unknown sub id", func(t *testing.T) { - // connect, open a stream - // inject an EVENT with a sub id that has no registration - // assert no panic, no deadlock, test completes cleanly - }) - - t.Run("drops unparseable envelope", func(t *testing.T) { - // connect, open a stream - // inject raw bytes that are not a valid envelope - // assert no panic, no deadlock, test completes cleanly - }) - - t.Run("routes eose to correct session", func(t *testing.T) { - // connect, open two streams (sub ids A and B), both with closeOnEOSE = false - // inject EOSE for sub id A - // assert A's session receives the signal (verify via a side effect, e.g. a counter) - // assert B's session does not receive the signal - }) - - t.Run("routes closed to session and request", func(t *testing.T) { - // connect, open a stream - // inject a CLOSED envelope with a reason string - // assert the session receives the closed signal and terminates - // assert request.closed yields a ReqClosed with the correct message - // both must receive the message: the session reacts, the caller is informed - }) -} - func TestRequestManager_Close(t *testing.T) { t.Run("terminates all sessions without deadlock", func(t *testing.T) { p, envoy := newMockEnvoy(t)