[#1227] morph/event: Release ants.Pool on listener stopping #1227
1 changed files with 1 additions and 0 deletions
|
@ -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()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue