diff --git a/device.go b/device.go index 1188b0d..ebcc81b 100644 --- a/device.go +++ b/device.go @@ -79,14 +79,17 @@ func (cli *RPCClient) run() { // encode gob enc := gob.NewEncoder(buf) cliBuffer := <-cli.FrameChan - enc.Encode(cliBuffer.BytesArray) + err := enc.Encode(cliBuffer.BytesArray) + if err != nil { + log.Panic(err) + } // zstd compress zenc, err := zstd.NewWriter(buf) if err != nil { log.Panic(err) } - err = zenc.Close() + err = zenc.Flush() if err != nil { log.Println(err) }