DocumentClient CreateDocumentQuery async

Question

Why is there no async version of CreateDocumentQuery?

This method for example could have been async:

    using (var client = new DocumentClient(new Uri(endpointUrl), authorizationKey, _connectionPolicy))
    {
        List<Property> propertiesOfUser =
            client.CreateDocumentQuery<Property>(_collectionLink)
                .Where(p => p.OwnerId == userGuid)
                .ToList();

        return propertiesOfUser;
    }

I think that CreateDocumentQuery simply creates a query and does not execute it. You could probably use ToListAsync instead of ToList to execute the query asynchronously. — Yacoub Massad
– Yacoub Massad, Commented Sep 5, 2016 at 22:09

Kasam Shaikh · Accepted Answer · 2016-09-06 13:22:21Z

20

Good query,

Just try below code to have it in async fashion.

DocumentQueryable.CreateDocumentQuery method creates a query for documents under a collection.

 // Query asychronously.
using (var client = new DocumentClient(new Uri(endpointUrl), authorizationKey, _connectionPolicy))
{
     var propertiesOfUser =
        client.CreateDocumentQuery<Property>(_collectionLink)
            .Where(p => p.OwnerId == userGuid)
            .AsDocumentQuery(); // Replaced with ToList()


while (propertiesOfUser.HasMoreResults) 
{
    foreach(Property p in await propertiesOfUser.ExecuteNextAsync<Property>())
     {
         // Iterate through Property to have List or any other operations
     }
}


}

edited Sep 6, 2016 at 13:22

answered Sep 6, 2016 at 10:04

Kasam Shaikh

3182 silver badges7 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Michael Freidgeim · Accepted Answer · 2018-03-16 13:48:51Z

Based on Kasam Shaikh's answer I've created ToListAsync extensions

  public static async Task<List<T>> ToListAsync<T>(this IDocumentQuery<T> queryable)
        {
            var list = new List<T>();
            while (queryable.HasMoreResults)
            {   //Note that ExecuteNextAsync can return many records in each call
                var response = await queryable.ExecuteNextAsync<T>();
                list.AddRange(response);
            }
            return list;
        }
        public static async Task<List<T>> ToListAsync<T>(this IQueryable<T> query)
        {
            return await query.AsDocumentQuery().ToListAsync();
        }

You can use it

var propertiesOfUser = await 
            client.CreateDocumentQuery<Property>(_collectionLink)
                .Where(p => p.OwnerId == userGuid)
                .ToListAsync()

Note that request to have CreateDocumentQuery async is open on github

Collectives™ on Stack Overflow

DocumentClient CreateDocumentQuery async

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related