diff --git a/manager.go b/manager.go index 2d3a955..a9a774e 100644 --- a/manager.go +++ b/manager.go @@ -92,10 +92,7 @@ func (m *Manager) Start() { m.Quit <- true - //TODO: wait on Quit signal from any WorkerUnit case p := <-m.panic: - //TODO: refactor shutdown procedure and reuse here - // send shutdown event to all worker units for name, w := range m.workers { if w.isPaniced {