fix: close pubsub

33cn · Aug 3, 2021 · aca60b8 · aca60b8
1 parent a3d45a7
commit aca60b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/system/p2p/dht/p2p.go b/system/p2p/dht/p2p.go
@@ -204,7 +204,7 @@ func (p *P2P) CloseP2P() {
 
 	protocol.ClearEventHandler()
 	if !p.isRestart() {
-		p.mgr.PubSub.Unsub(p.subChan)
+		p.mgr.PubSub.Shutdown()
 
 	}
 	p.host.Close()