cyberpresidentvanellope/tgstation-server
1
0
Fork 0
mirror of https://github.com/tgstation/tgstation-server.git synced 2026-07-19 20:13:45 +01:00
Code Issues Packages Projects Releases Wiki Activity

Simplify logic flow in JobsHubTests

Browse Source
This commit is contained in:
Jordan Dominion
2023-11-05 09:00:44 -05:00
parent cab8ce68f5
commit 2c82da46f6
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/Tgstation.Server.Tests/Live/Instance/JobsHubTests.cs
+2 -7
View File
@@ -92,13 +92,12 @@ namespace Tgstation.Server.Tests.Live.Instance
public async Task Run(CancellationToken cancellationToken)
{
var neverReceiverTcs = new TaskCompletionSource();
var neverReceiver = new ShouldNeverReceiveUpdates()
{
Callback = job =>
{
if (!permlessIsPermed)
neverReceiverTcs.TrySetException(new Exception($"ShouldNeverReceiveUpdates received an update for job {job.Id}!"));
finishTcs.TrySetException(new Exception($"ShouldNeverReceiveUpdates received an update for job {job.Id}!"));
else
lock (permlessSeenJobs)
permlessSeenJobs.Add(job.Id.Value);
@@ -131,13 +130,9 @@ namespace Tgstation.Server.Tests.Live.Instance
return Task.CompletedTask;
};
var completedTask = await Task.WhenAny(finishTcs.Task, neverReceiverTcs.Task);
await completedTask;
await finishTcs.Task;
}
neverReceiverTcs.TrySetResult();
await neverReceiverTcs.Task;
var allInstances = await permedUser.Instances.List(null, cancellationToken);
async ValueTask<List<JobResponse>> CheckInstance(InstanceResponse instance)