Skip to content
This repository was archived by the owner on Sep 29, 2024. It is now read-only.

Commit a16a474

Browse files
sshaplygingoogollee
authored andcommitted
ref
1 parent bd82ad3 commit a16a474

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

parser/decoder.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,7 @@ func (d *Decoder) DecodeHeader(header *Header, event *string) error {
7171
if ft != session.TEXT {
7272
return errInvalidFirstPacketType
7373
}
74+
7475
d.lastFrame = r
7576
br, ok := r.(byteReader)
7677
if !ok {
@@ -154,8 +155,9 @@ func (d *Decoder) DecodeArgs(types []reflect.Type) ([]reflect.Value, error) {
154155
}
155156

156157
func (d *Decoder) readUint64FromText(r byteReader) (uint64, bool, error) {
157-
ret := uint64(0)
158-
hasRead := false
158+
var ret uint64
159+
var hasRead bool
160+
159161
for {
160162
b, err := r.ReadByte()
161163
if err != nil {
@@ -176,7 +178,8 @@ func (d *Decoder) readUint64FromText(r byteReader) (uint64, bool, error) {
176178

177179
func (d *Decoder) readString(r byteReader, until byte) (string, error) {
178180
var ret bytes.Buffer
179-
hasRead := false
181+
var hasRead bool
182+
180183
for {
181184
b, err := r.ReadByte()
182185
if err != nil {
@@ -366,5 +369,6 @@ func (d *Decoder) detachBuffer(v reflect.Value, buffers []Buffer) error {
366369
}
367370
}
368371
}
372+
369373
return nil
370374
}

0 commit comments

Comments
 (0)