fix: added single thread per event

qvistgaard · Feb 24, 2024 · f268a90 · f268a90
1 parent 8db442a
commit f268a90
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/rms/runner.go b/internal/rms/runner.go
@@ -67,11 +67,11 @@ func (r *Runner) processEvents() error {
 				id := e.Car().Id()
 				if id > 0 {
 					if c, ok, _ := r.cars.Get(id); ok {
-						c.UpdateFromEvent(e)
+						go c.UpdateFromEvent(e)
 					}
 				}
 			}
-			r.race.UpdateFromEvent(e)
+			go r.race.UpdateFromEvent(e)
 			log.Tracef("processing time: %s", time.Now().Sub(start))
 		}
 	}