From d6c9707ad05a800d50d812fdaa37f2e5e057b7ff Mon Sep 17 00:00:00 2001 From: Silvan Date: Fri, 27 Nov 2020 15:32:26 +0100 Subject: [PATCH] fix(spooler): fast start (#1023) --- internal/eventstore/spooler/spooler.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/internal/eventstore/spooler/spooler.go b/internal/eventstore/spooler/spooler.go index d670d7cfd..d95f45ad4 100644 --- a/internal/eventstore/spooler/spooler.go +++ b/internal/eventstore/spooler/spooler.go @@ -50,10 +50,12 @@ func (s *Spooler) Start() { } }(i) } - for _, handler := range s.handlers { - handler := &spooledHandler{Handler: handler, locker: s.locker, queuedAt: time.Now(), eventstore: s.eventstore} - s.queue <- handler - } + go func() { + for _, handler := range s.handlers { + handler := &spooledHandler{Handler: handler, locker: s.locker, queuedAt: time.Now(), eventstore: s.eventstore} + s.queue <- handler + } + }() } func requeueTask(task *spooledHandler, queue chan<- *spooledHandler) {