eth/fetcher: fix test to avoid hanging. Partial fix for #23331

eth/fetcher/tx_fetcher_test.go

@@ -304,7 +304,7 @@ func TestTransactionFetcherSingletonRequesting(t *testing.T) {
 func TestTransactionFetcherFailedRescheduling(t *testing.T) {
 	// Create a channel to control when tx requests can fail
 	proceed := make(chan struct{})
-
+	defer close(proceed)
 	testTransactionFetcherParallel(t, txFetcherTest{
 		init: func() *TxFetcher {
 			return NewTxFetcher(
@@ -1263,6 +1263,17 @@ func testTransactionFetcher(t *testing.T, tt txFetcherTest) {
 	fetcher.Start()
 	defer fetcher.Stop()
 
+	defer func() { // drain the wait chan on exit
+		for {
+			select {
+			case <-wait:
+				continue
+			default:
+				return
+			}
+		}
+	}()
+
 	// Crunch through all the test steps and execute them
 	for i, step := range tt.steps {
 		switch step := step.(type) {