bugfix re-used buffer
This commit is contained in:
parent
494957c1c4
commit
38054cf331
|
@ -33,8 +33,8 @@ func (d *Decoder) StreamDecode(handler Handler, bufferSize int) error {
|
|||
}
|
||||
|
||||
go func() {
|
||||
b := make([]byte, bufferSize)
|
||||
for {
|
||||
b := make([]byte, bufferSize)
|
||||
//fmt.Println("loopers gonna loop")
|
||||
n, err := d.r.Read(b)
|
||||
if n > 0 {
|
||||
|
|
Loading…
Reference in New Issue