Skip to content

Commit 49f28f3

Browse files
committed
fix: remove FlushStop so reactor-specific-peers can be used
1 parent 35d67a6 commit 49f28f3

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

p2p/pex/pex_reactor.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,6 @@ func (r *Reactor) Receive(e p2p.Envelope) {
265265
r.SendAddrs(e.Src, r.book.GetSelectionWithBias(biasToSelectNewPeers))
266266
go func() {
267267
// In a go-routine so it doesn't block .Receive.
268-
e.Src.FlushStop()
269268
r.Switch.StopPeerGracefully(e.Src, r.String())
270269
}()
271270

0 commit comments

Comments
 (0)