recycle json decoder
This commit is contained in:
4
utils.go
4
utils.go
@ -77,9 +77,11 @@ func readSocketGeneric[T any](ctx context.Context, socket string, body io.Reader
|
|||||||
defer close(out)
|
defer close(out)
|
||||||
defer r.Close()
|
defer r.Close()
|
||||||
|
|
||||||
|
dec := json.NewDecoder(r)
|
||||||
|
|
||||||
for ctx.Err() == nil {
|
for ctx.Err() == nil {
|
||||||
value := new(T)
|
value := new(T)
|
||||||
if err := json.NewDecoder(r).Decode(value); err != nil {
|
if err := dec.Decode(value); err != nil {
|
||||||
if errors.Is(err, io.EOF) {
|
if errors.Is(err, io.EOF) {
|
||||||
return
|
return
|
||||||
} else {
|
} else {
|
||||||
|
Reference in New Issue
Block a user