Fix busy wait loop in benchmark stream (#1703)

elastic · Feb 27, 2024 · 6cd0720 · 6cd0720
1 parent 30c624a
commit 6cd0720
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/benchrunner/runners/stream/runner.go b/internal/benchrunner/runners/stream/runner.go
@@ -206,12 +206,14 @@ func (r *runner) wipeDataStreamsOnSetup() error {
 func (r *runner) run() (err error) {
 	r.streamData()
 
+	ticker := time.NewTicker(1 * time.Second)
+	defer ticker.Stop()
 	for {
 		select {
 		case err = <-r.errChanGenerators:
 			close(r.done)
 			return err
-		default:
+		case <-ticker.C:
 			if signal.SIGINT() {
 				close(r.done)
 				return nil