diff --git a/chainntnfs/btcdnotify/btcd.go b/chainntnfs/btcdnotify/btcd.go index 43e05a6c..d0c89b08 100644 --- a/chainntnfs/btcdnotify/btcd.go +++ b/chainntnfs/btcdnotify/btcd.go @@ -159,6 +159,9 @@ func (b *BtcdNotifier) Stop() error { close(confClient.negativeConf) } } + for _, epochClient := range b.blockEpochClients { + close(epochClient) + } return nil }