diff --git a/services/opencode/src/main/kotlin/com/getcode/opencode/internal/bidi/BidirectionalStreamReference.kt b/services/opencode/src/main/kotlin/com/getcode/opencode/internal/bidi/BidirectionalStreamReference.kt
index 146232f94..c9cdd1d6c 100644
--- a/services/opencode/src/main/kotlin/com/getcode/opencode/internal/bidi/BidirectionalStreamReference.kt
+++ b/services/opencode/src/main/kotlin/com/getcode/opencode/internal/bidi/BidirectionalStreamReference.kt
@@ -102,6 +102,7 @@ class BidirectionalStreamReference<Request, Response>(
         onConnect = null
         isStreamActive = false
         cancelTimeout()
+        supervisorJob.cancel()
         release()
     }