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