GameCult/CultLib
Watch
9
0
Fork
You've already forked CultLib
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions 6

Harden CultMesh subscription readiness

Browse source
This commit is contained in:
Meta Vens 2026-07-13 04:19:54 +01:00
commit 61257d5a20
4 changed files with 96 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/GameCult.Networking/CultNetDatabaseSubscriptionClient.cs
View file

@ -53,13 +53,9 @@ namespace GameCult.Networking
if (string.IsNullOrWhiteSpace(subscriptionId)) throw new ArgumentException("Subscription id is required.", nameof(subscriptionId));
var messageId = Guid.NewGuid().ToString("N");
TaskCompletionSource<IReadOnlyList<object>>? completion = null;
if (includeSnapshot)
{
completion = new TaskCompletionSource<IReadOnlyList<object>>(TaskCreationOptions.RunContinuationsAsynchronously);
if (!_initialSnapshots.TryAdd(messageId, completion))
throw new InvalidOperationException($"Duplicate database subscription message id '{messageId}'.");
}
var completion = new TaskCompletionSource<IReadOnlyList<object>>(TaskCreationOptions.RunContinuationsAsynchronously);
if (!_initialSnapshots.TryAdd(messageId, completion))
throw new InvalidOperationException($"Duplicate database subscription message id '{messageId}'.");
_client.SendCultNet(new CultNetDatabaseSubscribeMessage
{
@ -69,7 +65,7 @@ namespace GameCult.Networking
SchemaIds = schemaIds?.Where(value => !string.IsNullOrWhiteSpace(value)).Distinct(StringComparer.Ordinal).ToArray(),
IncludeSnapshot = includeSnapshot
});
return completion?.Task ?? Task.FromResult<IReadOnlyList<object>>(Array.Empty<object>());
return completion.Task;
}
/// <summary>Stops one live remote subscription.</summary>