diff --git a/rpc_client.go b/rpc_client.go index ea4396f..14e4b30 100644 --- a/rpc_client.go +++ b/rpc_client.go @@ -116,7 +116,7 @@ func (cli *RPCClient) run() { Compress(buf, cli.Frames) - if len(cli.Frames) >= 1000 { + if len(cli.Frames) >= 2 { var countbuf = 0 for _, frame := range cli.Frames { countbuf += len(frame)