CancellationToken per request about typedsignalr.client HOT 3 CLOSED

public interface IHub
{
    // Use CancellationToken.
    //     Note that you cannot actually write code like this.
    Task<int> Add(int x, int y, CancellationToken cancellationToken);
}

// client-side
//     This appears to be an unproblematic syntax.
//     Note that you cannot actually write code like this.
var hubProxy = hubConnection.CreateHubProxy<IHub>(cancellationTokenSource.Token);
var result = await hubProxy.Add(7, 99, cancellationTokenSource.Token);

// server-side
public class MyHub : Hub, IHub
{
    // SignalR Hub cannot handle this cancellationToken.
    public Task<int> Add(int x, int y, CancellationToken cancellationToken)
    {
    }
}

public interface IStreamingHub
{
    // server-to-client streaming
    IAsyncEnumerable<Person> GetStream(CancellationToken cancellationToken);
}

// client-side
//     This code can be written.
var hubProxy = hubConnection.CreateHubProxy<IStreamingHub>(cancellationTokenSource.Token);
var stream = hubProxy.GetStream(cancellationTokenSource.Token);

public class UnaryHub : Hub
{
    private readonly ILogger<UnaryHub> _logger;

    public UnaryHub(ILogger<UnaryHub> logger)
    {
        _logger = logger;
    }

    public override Task OnConnectedAsync()
    {
        _logger.Log(LogLevel.Information, "OnConnectedAsync");
        return base.OnConnectedAsync();
    }

    public override Task OnDisconnectedAsync(Exception? exception)
    {
        _logger.Log(LogLevel.Information, "OnDisconnectedAsync");
        return base.OnDisconnectedAsync(exception);
    }

    public async Task<int> Add(int x, int y)
    {
        await Task.Delay(TimeSpan.FromSeconds(10), this.Context.ConnectionAborted);
        _logger.Log(LogLevel.Information, "UnaryHub.Add");
        return x + y;
    }
}

var connection = new HubConnectionBuilder()
    .WithUrl("http://localhost:5105/Hubs/UnaryHub")
    .Build();

try
{
    await connection.StartAsync();

    var cts = new CancellationTokenSource();

    Console.WriteLine("InvokeAsync: Add");
    var task = connection.InvokeAsync<int>("Add", 22, 77, cts.Token);

    await Task.Delay(TimeSpan.FromSeconds(2));
    cts.Cancel();

    var result = await task;
    Console.WriteLine($"result {result}");
}
catch (Exception ex)
{
    Console.WriteLine(ex.Message);
}

Console.WriteLine("waiting");
await Task.Delay(TimeSpan.FromSeconds(10));

Console.WriteLine("StopAsync");
await connection.StopAsync();

Console.ReadLine();