fix a condition bug

2015-07-28 18:26:53 -07:00
parent 0231ff14bc
commit 75cfec3f72
1 changed files with 1 additions and 1 deletions
--- a/server.go
+++ b/server.go
@ -345,7 +345,7 @@ func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transp
 		ss.traceInfo.tr.LazyLog(&ss.traceInfo.firstLine, false)
 		defer func() {
 			ss.mu.Lock()
-			if err != nil {
+			if err != nil && err != io.EOF {
 				ss.traceInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
 				ss.traceInfo.tr.SetError()
 			}