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

Add missing subscription CancellationToken

Browse Source
This commit is contained in:
Jordan Dominion
2024-09-24 07:06:36 -04:00
parent e5f08c3ed9
commit 5faf6eee9c
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Tgstation.Server.Host/GraphQL/Subscription.cs
+5 -2
View File
@@ -1,4 +1,5 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using HotChocolate;
@@ -34,16 +35,18 @@ namespace Tgstation.Server.Host.GraphQL
/// <param name="receiver">The <see cref="ITopicEventReceiver"/>.</param>
/// <param name="invalidationTracker">The <see cref="ISessionInvalidationTracker"/>.</param>
/// <param name="authenticationContext">The <see cref="IAuthenticationContext"/> for the request.</param>
/// <param name="cancellationToken">The <see cref="CancellationToken"/> for the operation.</param>
/// <returns>A <see cref="ValueTask{TResult}"/> resulting in a <see cref="ISourceStream{TMessage}"/> of the <see cref="SessionInvalidationReason"/> for the <paramref name="authenticationContext"/>.</returns>
public ValueTask<ISourceStream<SessionInvalidationReason>> SessionInvalidatedStream(
[Service] ITopicEventReceiver receiver,
[Service] ISessionInvalidationTracker invalidationTracker,
[Service] IAuthenticationContext authenticationContext)
[Service] IAuthenticationContext authenticationContext,
CancellationToken cancellationToken)
{
ArgumentNullException.ThrowIfNull(receiver);
ArgumentNullException.ThrowIfNull(invalidationTracker);
var subscription = receiver.SubscribeAsync<SessionInvalidationReason>(SessionInvalidatedTopic(authenticationContext));
var subscription = receiver.SubscribeAsync<SessionInvalidationReason>(SessionInvalidatedTopic(authenticationContext), cancellationToken);
invalidationTracker.TrackSession(authenticationContext);
return subscription;
}