Commit 8028bc49 authored by Jeromy's avatar Jeromy Committed by Steven Allen

shutdown notifications engine when closing a bitswap session

License: MIT
Signed-off-by: default avatarJeromy <jeromyj@gmail.com>
parent c26feecf
......@@ -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++ {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment