Fix listen subscription exit

qdm12 · qdm12 · commit c2ebb6f86443 · 2025-04-30T10:23:26.000+02:00
diff --git a/tests/load/listen/newhead.go b/tests/load/listen/newhead.go
@@ -65,7 +65,11 @@ func subscriptionChToSignal(listenStop <-chan struct{}, listenDone, ready chan<-
 		case <-listenStop:
 			return
 		case header := <-subCh:
-			newHeadCh <- header.Number.Uint64()
+			select {
+			case newHeadCh <- header.Number.Uint64():
+			case <-listenStop:
+				return
+			}
 		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,11 @@ func subscriptionChToSignal(listenStop <-chan struct{}, listenDone, ready chan<-`
`65`	`65`	`case <-listenStop:`
`66`	`66`	`return`
`67`	`67`	`case header := <-subCh:`
`68`		`- newHeadCh <- header.Number.Uint64()`
	`68`	`+ select {`
	`69`	`+ case newHeadCh <- header.Number.Uint64():`
	`70`	`+ case <-listenStop:`
	`71`	`+ return`
	`72`	`+ }`
`69`	`73`	`}`
`70`	`74`	`}`
`71`	`75`	`}`