From 3a8eef2dec19241d1638d2aad8b30d5459b4ac35 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Wed, 11 Jan 2017 15:10:30 +0100 Subject: [PATCH] don't do normal close in error case --- transport/ray/direct.go | 1 - 1 file changed, 1 deletion(-) diff --git a/transport/ray/direct.go b/transport/ray/direct.go index bb838f4ef..1acc39fae 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++ {