Allow stopping even if workers result channel is full. (#74)

Fantom-foundation · Apr 22, 2024 · 570203f · 570203f
1 parent 2772ef3
commit 570203f
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/db/substate_iterator.go b/db/substate_iterator.go
@@ -105,7 +105,12 @@ func (i *substateIterator) start(numWorkers int) {
 						errCh <- err
 						return
 					}
-					resultChs[id] <- transaction
+					select {
+					case resultChs[id] <- transaction:
+					case <-i.stopCh:
+						return
+
+					}
 				}
 
 			}