Merge pull request #487 from lpxxn/master

fix streamming error io.ErrUnexpectedEOF

server/rpc_server.go

@@ -157,7 +157,6 @@ func (s *rpcServer) ServeConn(sock transport.Socket) {
 
 		// TODO: handle error better
 		if err := handler(ctx, request, response); err != nil {
-			if err != lastStreamResponseError {
 			// write an error response
 			err = rcodec.Write(&codec.Message{
 				Header: msg.Header,
@@ -168,7 +167,6 @@ func (s *rpcServer) ServeConn(sock transport.Socket) {
 			if err != nil {
 				log.Logf("rpc: unable to write error response: %v", err)
 			}
-			}
 			s.wg.Done()
 			return
 		}