diff --git a/rpc/server.go b/rpc/server.go index b2f6158..f39bdaa 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -83,11 +83,6 @@ func (r *RpcServer) Resolve(ctx context.Context, rd io.Reader, w io.Writer, para for { req := new(RpcRequest) if err := dec.Decode(req); err != nil { - if err == io.EOF { - break - } - r.logger.Logf("Can't read body: %v", err) - WriteError(ErrCodeParseError, enc) break } exec := func() {