Skip to content

Commit 2973fea

Browse files
committed
reuse last buffer
to pickup what's left in it, instead of create new buffer each time, this should fix #1
1 parent 54ed41e commit 2973fea

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

connection.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,9 +199,11 @@ func (c *SocketConnection) Handle() {
199199

200200
done := make(chan bool)
201201

202+
rbuf := bufio.NewReaderSize(c, ReadBufferSize)
203+
202204
go func() {
203205
for {
204-
msg, err := newMessage(bufio.NewReaderSize(c, ReadBufferSize), true)
206+
msg, err := newMessage(rbuf, true)
205207

206208
if err != nil {
207209
c.err <- err

0 commit comments

Comments
 (0)