diff --git a/exchange/bitswap/session.go b/exchange/bitswap/session.go
index 07444ad36..049be4e9e 100644
--- 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) {
+	s.notif.Shutdown()
 	bs.sessLk.Lock()
 	defer bs.sessLk.Unlock()
 	for i := 0; i < len(bs.sessions); i++ {