Fix wrong OnLeave event handling in stream
@@ -128,8 +128,6 @@ func (r *streamReactor) OnLeave(id module.PeerID) {
r.streams[i] = r.streams[last]
r.streams[last] = nil
r.streams = r.streams[:last]
- break
- }
if s.repostTimer != nil {
s.repostTimer.Stop()
s.repostTimer = nil
@@ -138,6 +136,8 @@ func (r *streamReactor) OnLeave(id module.PeerID) {
s.ackPostTimer.Stop()
s.ackPostTimer = nil
}
+ break
+ }
}
}
