diff --git a/datagramsession/manager.go b/datagramsession/manager.go index 60b701ab..ae332bf6 100644 --- a/datagramsession/manager.go +++ b/datagramsession/manager.go @@ -92,7 +92,10 @@ func (m *manager) shutdownSessions(err error) { byRemote: true, } for _, s := range m.sessions { - s.close(closeSessionErr) + m.unregisterSession(&unregisterSessionEvent{ + sessionID: s.ID, + err: closeSessionErr, + }) } }