defer subscription closes

libp2p · Feb 27, 2020 · ae33956 · ae33956
1 parent f5386bd
commit ae33956
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/p2p/host/relay/autorelay.go b/p2p/host/relay/autorelay.go
@@ -87,10 +87,13 @@ func (ar *AutoRelay) hostAddrs(addrs []ma.Multiaddr) []ma.Multiaddr {
 func (ar *AutoRelay) background(ctx context.Context) {
 	subNatPublic, _ := ar.host.EventBus().Subscribe(new(event.EvtLocalRoutabilityPublic))
 	pubChan := subNatPublic.Out()
+	defer subNatPublic.Close()
 	subNatPrivate, _ := ar.host.EventBus().Subscribe(new(event.EvtLocalRoutabilityPrivate))
 	priChan := subNatPrivate.Out()
+	defer subNatPrivate.Close()
 	subNatUnknown, _ := ar.host.EventBus().Subscribe(new(event.EvtLocalRoutabilityUnknown))
 	unkChan := subNatUnknown.Out()
+	defer subNatUnknown.Close()
 
 	// when true, we need to identify push
 	push := false