public async Task TransferFileAsync(string connectionId, IAsyncEnumerable<byte[]> bytes, CancellationToken cancellationToken)
{
await foreach (var buffer in bytes)
{
cancellationToken.ThrowIfCancellationRequested();
await Clients.Client(connectionId).SendAsync("ReceiveFile", buffer, cancellationToken);
}
}
public async Task TransferFileAsync(string connectionId, IAsyncEnumerable<byte[]> bytes, CancellationToken cancellationToken)
{
await foreach (var buffer in bytes)
{
cancellationToken.ThrowIfCancellationRequested();
await Clients.Client(connectionId).SendAsync("ReceiveFile", buffer, cancellationToken);
}
}