From 3c5bad2f67329fddc1bcd15c1b11a01b31a7d07a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E6=80=9D=E6=95=8F?= Date: Thu, 1 Sep 2022 15:02:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0TAP=E6=B5=8B=E8=AF=95(TODO=20=E8=A7=A3?= =?UTF-8?q?=E6=9E=90arp)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc_client.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rpc_client.go b/rpc_client.go index 3d1e7d2..b6bdbb5 100644 --- a/rpc_client.go +++ b/rpc_client.go @@ -95,7 +95,7 @@ func (cli *RPCClient) run() { defer stream.CloseSend() var ticker = time.NewTicker(time.Millisecond * 20) - var frames [][]byte + buf := bytes.NewBuffer(nil) for { @@ -105,8 +105,8 @@ func (cli *RPCClient) run() { } buf.Reset() cli.Lock(func() bool { - Compress(buf, frames) - frames = frames[:0] + Compress(buf, cli.Frames) + cli.Frames = cli.Frames[:0] return true })