parent
e8ba87e806
commit
cb81d4f3c2
|
@ -139,9 +139,8 @@ func (codec *EchoPackage) DecodeBuffer(msg []byte) (err error) {
|
||||||
return ErrNotEnoughStream
|
return ErrNotEnoughStream
|
||||||
}
|
}
|
||||||
|
|
||||||
bBuf := msg[echoPkgHeaderLen:codec.H.Len]
|
|
||||||
codec.B = make([]byte, codec.H.Len)
|
codec.B = make([]byte, codec.H.Len)
|
||||||
copy(codec.B, bBuf)
|
copy(codec.B, msg[echoPkgHeaderLen:echoPkgHeaderLen+int(codec.H.Len)])
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -207,9 +206,7 @@ func (codec *EchoPackage) DecodeWsMessage(msg wsutil.Message) (err error) {
|
||||||
if len(msg.Payload)-echoPkgHeaderLen < int(codec.H.Len) {
|
if len(msg.Payload)-echoPkgHeaderLen < int(codec.H.Len) {
|
||||||
return ErrNotEnoughStream
|
return ErrNotEnoughStream
|
||||||
}
|
}
|
||||||
|
|
||||||
bBuf := msg.Payload[echoPkgHeaderLen:codec.H.Len]
|
|
||||||
codec.B = make([]byte, codec.H.Len)
|
codec.B = make([]byte, codec.H.Len)
|
||||||
copy(codec.B, bBuf)
|
copy(codec.B, msg.Payload[echoPkgHeaderLen:echoPkgHeaderLen+int(codec.H.Len)])
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue