fix: fix dispatcher pending delete logic

This commit is contained in:
healthykim 2025-12-04 14:52:04 +09:00
parent 32de571acd
commit b35f62794f

View file

@ -250,6 +250,9 @@ func (p *Peer) dispatcher() {
// it can wait for a handler response and dispatch the data.
res.Time = res.recv.Sub(res.Req.Sent)
resOp.fail <- nil
// Stop tracking the request, the response dispatcher will deliver
delete(pending, res.id)
}
case <-p.term: