RepoMirrors
/
osu
mirror of https://github.com/ppy/osu
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace `SpectatorScreen` event flow with realm subscriptions

This commit is contained in:
Dean Herbert 2021-12-17 19:26:41 +09:00
parent 5c0d31ed24
commit 86ce2256be
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
osu.Game/Screens/Spectate/SpectatorScreen.cs
View File

@ -1,6 +1,7 @@
// Copyright (c) ppy Pty Ltd <contact@ppy.sh>. Licensed under the MIT Licence.
// See the LICENCE file in the repository root for full licence text.
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
@ -54,6 +55,11 @@ protected SpectatorScreen(params int[] users)
this.users.AddRange(users);
}
[Resolved]
private RealmContextFactory realmContextFactory { get; set; }
private IDisposable realmSubscription;
protected override void LoadComplete()
{
base.LoadComplete();
@ -73,7 +79,17 @@ protected override void LoadComplete()
playingUserStates.BindTo(spectatorClient.PlayingUserStates);
playingUserStates.BindCollectionChanged(onPlayingUserStatesChanged, true);
beatmaps.ItemUpdated += beatmapUpdated;
realmSubscription = realmContextFactory.Context
.All<BeatmapSetInfo>()
.Where(s => !s.DeletePending)
.QueryAsyncWithNotifications((items, changes, ___) =>
{
if (changes?.InsertedIndices == null)
return;
foreach (int c in changes.InsertedIndices)
beatmapUpdated(items[c]);
});
foreach ((int id, var _) in userMap)
spectatorClient.WatchUser(id);
@ -219,8 +235,7 @@ protected override void Dispose(bool isDisposing)
spectatorClient.StopWatchingUser(userId);
}
if (beatmaps != null)
beatmaps.ItemUpdated -= beatmapUpdated;
realmSubscription?.Dispose();
}
}
}