mirror of
https://github.com/osukey/osukey.git
synced 2025-08-08 09:03:50 +09:00
Simplify ack re-perform flow
This commit is contained in:
@ -108,15 +108,7 @@ namespace osu.Game.Online.Chat
|
|||||||
connector.Start();
|
connector.Start();
|
||||||
|
|
||||||
apiState.BindTo(api.State);
|
apiState.BindTo(api.State);
|
||||||
apiState.BindValueChanged(_ => performChatAckRequest(), true);
|
apiState.BindValueChanged(_ => SendAck(), true);
|
||||||
}
|
|
||||||
|
|
||||||
private void performChatAckRequest()
|
|
||||||
{
|
|
||||||
if (apiState.Value != APIState.Online)
|
|
||||||
return;
|
|
||||||
|
|
||||||
SendAck();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@ -397,6 +389,9 @@ namespace osu.Game.Online.Chat
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public void SendAck()
|
public void SendAck()
|
||||||
{
|
{
|
||||||
|
if (apiState.Value != APIState.Online)
|
||||||
|
return;
|
||||||
|
|
||||||
var req = new ChatAckRequest
|
var req = new ChatAckRequest
|
||||||
{
|
{
|
||||||
SinceMessageId = lastMessageId,
|
SinceMessageId = lastMessageId,
|
||||||
@ -421,7 +416,7 @@ namespace osu.Game.Online.Chat
|
|||||||
void scheduleNextRequest()
|
void scheduleNextRequest()
|
||||||
{
|
{
|
||||||
scheduledAck?.Cancel();
|
scheduledAck?.Cancel();
|
||||||
scheduledAck = Scheduler.AddDelayed(performChatAckRequest, 60000);
|
scheduledAck = Scheduler.AddDelayed(SendAck, 60000);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user