ES Scroll Query Helper

1-Example.cs

public static void Main()
{
    var esClient = new ElasticClient(new Uri("http://localhost:9200"));

    var response = esClient
        .Search<object>(s => s
            .Index("sample_index")
            .AllTypes()
            .Scroll("1m"));

    foreach (IHit<dynamic> item in response.ToEnumerable(esClient, "1m"))
    {
        Console.WriteLine(item.Source.Title);
    }
}

2-ElasticsearchScrollIterator.cs

namespace Cludo.ElasticSearch
{

    public static class SearchResponseExtensions
    {
        public static IEnumerable<IHit<T>> ToEnumerable<T>(this ISearchResponse<T> searchResponse, IElasticClient client, Time scrollTime)
            where T : class
        {
            return new ElasticsearchScrollIterator<T>(client, searchResponse, scrollTime);
        }
    }

    public class ElasticsearchScrollIterator<T> : IEnumerable<IHit<T>> where T : class
    {
        private IElasticClient _client;
        private ISearchResponse<T> _searchResponse;
        private readonly Time _scrollTime;

        public ElasticsearchScrollIterator(IElasticClient client, ISearchResponse<T> searchResponse, Time scrollTime)
        {
            _client = client;
            _searchResponse = searchResponse;
            _scrollTime = scrollTime;
        }

        public IEnumerator<IHit<T>> GetEnumerator()
        {
            while (_searchResponse.Documents.Any())
            {
                foreach (var hit in _searchResponse.Hits)
                {
                    yield return hit;
                }

                _searchResponse = _client.Scroll<T>(_scrollTime, _searchResponse.ScrollId);
            }
        }

        IEnumerator IEnumerable.GetEnumerator()
        {
            throw new NotImplementedException();
        }
    }
}