종료시 콜백 호출
This commit is contained in:
@ -605,6 +605,12 @@ func upgrade_core(sh *subhandler, conn *websocket.Conn, accid primitive.ObjectID
|
|||||||
sh.callReceiver.OnClientMessageReceived(c.sender, BinaryMessage, r)
|
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.redisSync.Del(context.Background(), accid.Hex())
|
||||||
sh.connWaitGroup.Done()
|
sh.connWaitGroup.Done()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user