[#1227] morph/event: Release ants.Pool on listener stopping
Some checks failed
DCO action / DCO (pull_request) Successful in 7m35s
Build / Build Components (1.22) (pull_request) Successful in 9m34s
Build / Build Components (1.21) (pull_request) Successful in 9m42s
Tests and linters / gopls check (pull_request) Successful in 15m7s
Tests and linters / Lint (pull_request) Successful in 15m45s
Vulncheck / Vulncheck (pull_request) Successful in 18m17s
Tests and linters / Staticcheck (pull_request) Successful in 19m35s
Tests and linters / Tests (1.22) (pull_request) Failing after 21m42s
Tests and linters / Tests (1.21) (pull_request) Failing after 22m11s
Tests and linters / Tests with -race (pull_request) Failing after 22m32s
Pre-commit hooks / Pre-commit (pull_request) Successful in 39m9s

Signed-off-by: Denis Kirillov <d.kirillov@yadro.com>
This commit is contained in:
Denis Kirillov 2024-07-04 12:09:18 +03:00
parent 3a797e4682
commit 1995da8d3c

View file

@ -621,6 +621,7 @@ func (l *listener) RegisterNotaryHandler(hi NotaryHandlerInfo) {
func (l *listener) Stop() { func (l *listener) Stop() {
l.stopOnce.Do(func() { l.stopOnce.Do(func() {
l.subscriber.Close() l.subscriber.Close()
l.pool.Release()
}) })
l.wg.Wait() l.wg.Wait()
} }