diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index 4c8e523..a888470 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -605,6 +605,12 @@ func upgrade_core(sh *subhandler, conn *websocket.Conn, accid primitive.ObjectID sh.callReceiver.OnClientMessageReceived(c.sender, BinaryMessage, r) } } + if c.sender.disconnectedCallbacks != nil { + for _, f := range c.sender.disconnectedCallbacks { + f() + } + } + sh.redisSync.Del(context.Background(), accid.Hex()) sh.connWaitGroup.Done()