Skip to content

Commit c96127a

Browse files
committed
kite: make done channels bufferred to avoid potential leaks
1 parent 6c38b66 commit c96127a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ func (c *Client) receiveData() ([]byte, error) {
436436
return nil, errors.New("not connected")
437437
}
438438

439-
done := make(chan recv)
439+
done := make(chan recv, 1)
440440

441441
go func() {
442442
msg, err := session.Recv()

sockjsclient/xhr.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,7 @@ func (fr *frameReader) readFrame() {
379379
c byte
380380
err error
381381
}
382-
done := make(chan result)
382+
done := make(chan result, 1)
383383

384384
go func() {
385385
c, err := fr.r.ReadByte()

0 commit comments

Comments
 (0)