diff --git a/rpc_client.go b/rpc_client.go index aa8c1d0..3d1e7d2 100644 --- a/rpc_client.go +++ b/rpc_client.go @@ -106,6 +106,7 @@ func (cli *RPCClient) run() { buf.Reset() cli.Lock(func() bool { Compress(buf, frames) + frames = frames[:0] return true })