close the subscription on shutdown.

libp2p · Jun 26, 2019 · 1e75d6d · 1e75d6d
1 parent a2a6ae1
commit 1e75d6d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dht.go b/dht.go
@@ -107,6 +107,9 @@ func New(ctx context.Context, h host.Host, options ...opts.Option) (*IpfsDHT, er
 		// remove ourselves from network notifs.
 		dht.host.Network().StopNotify((*subscriberNotifee)(dht))
 
+		if dht.subscriptions.evtPeerIdentification != nil {
+			_ = dht.subscriptions.evtPeerIdentification.Close()
+		}
 		return nil
 	})