diff --git a/transport/ray/direct.go b/transport/ray/direct.go
index bb838f4e..1acc39fa 100644
--- a/transport/ray/direct.go
+++ b/transport/ray/direct.go
@@ -139,7 +139,6 @@ func (v *Stream) CloseError() {
 	defer swallowPanic()
 
 	close(v.err)
-	v.Close()
 
 	n := len(v.buffer)
 	for i := 0; i < n; i++ {