sim1222/osukey
1
1
Fork 0
mirror of https://github.com/osukey/osukey.git synced 2025-08-08 00:53:56 +09:00
Code Issues Packages Projects Releases Wiki Activity

Remove watched users on stop watching

Browse Source
This commit is contained in:
smoogipoo
2021-05-12 12:19:36 +09:00
parent 21fc0ba43b
commit ad11818868
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
osu.Game/Online/Spectator/SpectatorStreamingClient.cs
View File

@ -230,7 +230,7 @@ namespace osu.Game.Online.Spectator
connection.SendAsync(nameof(ISpectatorServer.StartWatchingUser), userId); connection.SendAsync(nameof(ISpectatorServer.StartWatchingUser), userId);
} }
public void StopWatchingUser(int userId) public virtual void StopWatchingUser(int userId)
{ {
lock (userLock) lock (userLock)
{ {

10
osu.Game/Tests/Visual/Spectator/TestSpectatorStreamingClient.cs
View File

@ -38,7 +38,8 @@ namespace osu.Game.Tests.Visual.Spectator
RulesetID = 0, RulesetID = 0,
}); });
userSentStateDictionary[userId] = false; userBeatmapDictionary.Remove(userId);
userSentStateDictionary.Remove(userId);
} }
public void SendFrames(int userId, int index, int count) public void SendFrames(int userId, int index, int count)
@ -66,10 +67,15 @@ namespace osu.Game.Tests.Visual.Spectator
sendState(userId, userBeatmapDictionary[userId]); sendState(userId, userBeatmapDictionary[userId]);
base.WatchUser(userId); base.WatchUser(userId);
watchingUsers.Add(userId); watchingUsers.Add(userId);
} }
public override void StopWatchingUser(int userId)
{
base.StopWatchingUser(userId);
watchingUsers.Remove(userId);
}
private void sendState(int userId, int beatmapId) private void sendState(int userId, int beatmapId)
{ {
((ISpectatorClient)this).UserBeganPlaying(userId, new SpectatorState ((ISpectatorClient)this).UserBeganPlaying(userId, new SpectatorState