sharpcompress/src/SharpCompress/LazyAsyncReadOnlyCollection.cs

#nullable disable
using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

namespace SharpCompress;

internal sealed class LazyAsyncReadOnlyCollection<T>(IAsyncEnumerable<T> source)
    : IAsyncEnumerable<T>
{
    private readonly List<T> _backing = new();
    private readonly IAsyncEnumerator<T> _source = source.GetAsyncEnumerator();
    private bool _fullyLoaded;

    private class LazyLoader(
        LazyAsyncReadOnlyCollection<T> lazyReadOnlyCollection,
        CancellationToken cancellationToken
    ) : IAsyncEnumerator<T>
    {
        private bool _disposed;
        private int _index = -1;

        public ValueTask DisposeAsync()
        {
            if (!_disposed)
            {
                _disposed = true;
            }
            return default;
        }

        public async ValueTask<bool> MoveNextAsync()
        {
            cancellationToken.ThrowIfCancellationRequested();
            if (_index + 1 < lazyReadOnlyCollection._backing.Count)
            {
                _index++;
                return true;
            }
            if (
                !lazyReadOnlyCollection._fullyLoaded
                && await lazyReadOnlyCollection._source.MoveNextAsync()
            )
            {
                lazyReadOnlyCollection._backing.Add(lazyReadOnlyCollection._source.Current);
                _index++;
                return true;
            }
            lazyReadOnlyCollection._fullyLoaded = true;
            return false;
        }

        #region IEnumerator<T> Members

        public T Current => lazyReadOnlyCollection._backing[_index];

        #endregion

        #region IDisposable Members

        public void Dispose()
        {
            if (!_disposed)
            {
                _disposed = true;
            }
        }

        #endregion
    }

    internal async ValueTask EnsureFullyLoaded()
    {
        if (!_fullyLoaded)
        {
            var loader = new LazyLoader(this, CancellationToken.None);
            while (await loader.MoveNextAsync())
            {
                // Intentionally empty
            }
            _fullyLoaded = true;
        }
    }

    internal IEnumerable<T> GetLoaded() => _backing;

    #region ICollection<T> Members

    public void Add(T item) => throw new NotSupportedException();

    public void Clear() => throw new NotSupportedException();

    public bool IsReadOnly => true;

    public bool Remove(T item) => throw new NotSupportedException();

    #endregion

    public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default) =>
        new LazyLoader(this, cancellationToken);
}