shutdown notifications engine when closing a bitswap session

License: MIT Signed-off-by: Jeromy <[email protected]>
ipfs · Feb 4, 2018 · 0b80b2c · 0b80b2c
1 parent 52301ce
commit 0b80b2c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/exchange/bitswap/session.go b/exchange/bitswap/session.go
@@ -83,6 +83,7 @@ func (bs *Bitswap) NewSession(ctx context.Context) *Session {
 }
 
 func (bs *Bitswap) removeSession(s *Session) {
+	bs.notifications.Shutdown()
 	bs.sessLk.Lock()
 	defer bs.sessLk.Unlock()
 	for i := 0; i < len(bs.sessions); i++ {