RepoMirrors/osu
1
0
Fork 0
mirror of https://github.com/ppy/osu synced 2024-12-11 17:42:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Replace TopLocalRank event flow with realm subscriptions

Browse Source
This commit is contained in:
Dean Herbert 2021-12-17 19:09:35 +09:00
parent fe8a5e867d
commit 6d60aa7d9c
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
osu.Game/Screens/Select/Carousel/TopLocalRank.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.Linq;
using osu.Framework.Allocation;
using osu.Framework.Bindables;
@ -19,9 +20,6 @@ namespace osu.Game.Screens.Select.Carousel
{
private readonly BeatmapInfo beatmapInfo;
[Resolved]
private ScoreManager scores { get; set; }
[Resolved]
private IBindable<RulesetInfo> ruleset { get; set; }
@ -40,26 +38,34 @@ namespace osu.Game.Screens.Select.Carousel
[BackgroundDependencyLoader]
private void load()
{
scores.ItemUpdated += scoreChanged;
scores.ItemRemoved += scoreChanged;
ruleset.ValueChanged += _ => fetchAndLoadTopScore();
fetchAndLoadTopScore();
}
private void scoreChanged(ScoreInfo score)
protected override void LoadComplete()
{
if (score.BeatmapInfoID == beatmapInfo.ID)
fetchAndLoadTopScore();
base.LoadComplete();
scoreSubscription = realmFactory.Context.All<ScoreInfo>().Where(s => s.BeatmapInfo.ID == beatmapInfo.ID).QueryAsyncWithNotifications((_, changes, ___) =>
{
if (changes == null)
return;
fetchTopScoreRank();
});
}
private IDisposable scoreSubscription;
private ScheduledDelegate scheduledRankUpdate;
private void fetchAndLoadTopScore()
{
// TODO: this lookup likely isn't required, we can use the results of the subscription directly.
var rank = fetchTopScoreRank();
scheduledRankUpdate = Schedule(() =>
scheduledRankUpdate = Scheduler.Add(() =>
{
Rank = rank;
@ -89,11 +95,7 @@ namespace osu.Game.Screens.Select.Carousel
{
base.Dispose(isDisposing);
if (scores != null)
{
scores.ItemUpdated -= scoreChanged;
scores.ItemRemoved -= scoreChanged;
}
scoreSubscription?.Dispose();
}
}
}