diff options
| author | Valery Piashchynski <[email protected]> | 2020-12-22 23:02:25 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2020-12-22 23:02:25 +0300 |
| commit | fd1e98bc6339abfa66523bf9d2208d00df8ee4bc (patch) | |
| tree | b679441276717e687a5b460ebeba7ad0eee69be9 /pkg/worker_watcher | |
| parent | 40b6c3169931a3fef62b649db19ff01dc685b7d4 (diff) | |
events listeners refactor, CLI initial commit
Diffstat (limited to 'pkg/worker_watcher')
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 918145e5..55191ce6 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -163,7 +163,6 @@ type workerWatcher struct { func (ww *workerWatcher) AddToWatch(workers []worker.BaseProcess) error { for i := 0; i < len(workers); i++ { ww.stack.Push(workers[i]) - workers[i].AddListener(ww.events.Push) go func(swc worker.BaseProcess) { ww.wait(swc) |