public static class QueryApiExtensions
{
    public static IAsyncEnumerable<FluxRecord> QueryAsyncEnumerable(this QueryApi queryApi,
        Query query, string? org = null, CancellationToken cancellationToken = default)
    {
       
       //Set up these options to be sure to not keep all previous data in the Channel. This might takes a lot of RAM.
       //The channel will only one record at a time.
       //The channel will recieve the next FluxRecord when a reader has read the previous one (and only one). 
        var options = new BoundedChannelOptions(1)
        {
            SingleWriter = true,
            SingleReader = true,
            FullMode = BoundedChannelFullMode.Wait
        };

        var buffer = Channel.CreateBounded<FluxRecord>(options);

        queryApi.QueryAsync(query,
            onNext: async (record) => await buffer.Writer.WriteAsync(record),
            onComplete: () => buffer.Writer.Complete(),
            onError: (e) => buffer.Writer.Complete(e),
            org: org,
            cancellationToken: cancellationToken);

        return buffer.Reader.ReadAllAsync(cancellationToken);
    }
}