using System.Text;

using System.Text.Json;

using System.Collections.Generic;

using System.Linq;

using System;

using System.IO;

using System.Threading.Tasks;

using System.Threading;

public static class Program

{

    public static async Task Main()

    {

        var chars = "["+ string.Join(",", Enumerable.Range(1, 10_000)) + "]";

        using var stream = new MemoryStream(Encoding.UTF8.GetBytes(chars));

        CancellationTokenSource cts = new CancellationTokenSource();

        cts.CancelAfter(50);

​

        await foreach (int item in JsonSerializer.DeserializeAsyncEnumerable<int>(stream, new JsonSerializerOptions(){DefaultBufferSize = 1024}, cancellationToken: cts.Token))

        {

            await Task.Delay(1);

            Console.WriteLine(item);

            Console.WriteLine(cts.IsCancellationRequested);

        }

    }

​

}