diff --git a/utils.go b/utils.go
index d63cc90..0f470a4 100644
--- a/utils.go
+++ b/utils.go
@@ -77,9 +77,11 @@ func readSocketGeneric[T any](ctx context.Context, socket string, body io.Reader
 		defer close(out)
 		defer r.Close()
 
+		dec := json.NewDecoder(r)
+
 		for ctx.Err() == nil {
 			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) {
 					return
 				} else {