fix async issues, add async tests

src/FluentCommand.EntityFactory/DataCommandExtensions.cs

@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace FluentCommand
@@ -64,5 +65,64 @@ public static TEntity QuerySingle<TEntity>(this IDataQuery dataQuery)
             return dataQuery.QuerySingle(ReaderFactory.EntityFactory<TEntity>);
         }
 
+
+
+        /// <summary>
+        /// Executes the command against the connection and converts the results to dynamic objects asynchronously.
+        /// </summary>
+        /// <param name="dataQuery">The <see cref="IDataQueryAsync"/> for this extension method.</param>
+        /// <param name="cancellationToken">The cancellation instruction.</param>
+        /// <returns>
+        /// An <see cref="T:System.Collections.Generic.IEnumerable`1" /> of dynamic objects.
+        /// </returns>
+        public static Task<IEnumerable<dynamic>> QueryAsync(this IDataQueryAsync dataQuery, CancellationToken cancellationToken = default(CancellationToken))
+        {
+            return dataQuery.QueryAsync(ReaderFactory.DynamicFactory, cancellationToken);
+        }
+
+        /// <summary>
+        /// Executes the command against the connection and converts the results to <typeparamref name="TEntity" /> objects asynchronously.
+        /// </summary>
+        /// <typeparam name="TEntity">The type of the entity.</typeparam>
+        /// <param name="dataQuery">The <see cref="IDataQueryAsync"/> for this extension method.</param>
+        /// <param name="cancellationToken">The cancellation instruction.</param>
+        /// <returns>
+        /// An <see cref="T:System.Collections.Generic.IEnumerable`1" /> of <typeparamref name="TEntity" /> objects.
+        /// </returns>
+        public static Task<IEnumerable<TEntity>> QueryAsync<TEntity>(this IDataQueryAsync dataQuery, CancellationToken cancellationToken = default(CancellationToken))
+            where TEntity : class, new()
+        {
+            return dataQuery.QueryAsync(ReaderFactory.EntityFactory<TEntity>, cancellationToken);
+        }
+
+
+        /// <summary>
+        /// Executes the query and returns the first row in the result as a dynamic object asynchronously.
+        /// </summary>
+        /// <param name="dataQuery">The <see cref="IDataQueryAsync"/> for this extension method.</param>
+        /// <param name="cancellationToken">The cancellation instruction.</param>
+        /// <returns>
+        /// A instance of a dynamic object if row exists; otherwise null.
+        /// </returns>
+        public static Task<dynamic> QuerySingleAsync(this IDataQueryAsync dataQuery, CancellationToken cancellationToken = default(CancellationToken))
+        {
+            return dataQuery.QuerySingleAsync(ReaderFactory.DynamicFactory, cancellationToken);
+        }
+
+        /// <summary>
+        /// Executes the query and returns the first row in the result as a <typeparamref name="TEntity" /> object asynchronously.
+        /// </summary>
+        /// <typeparam name="TEntity">The type of the entity.</typeparam>
+        /// <param name="dataQuery">The <see cref="IDataQueryAsync"/> for this extension method.</param>
+        /// <param name="cancellationToken">The cancellation instruction.</param>
+        /// <returns>
+        /// A instance of <typeparamref name="TEntity" /> if row exists; otherwise null.
+        /// </returns>
+        public static Task<TEntity> QuerySingleAsync<TEntity>(this IDataQueryAsync dataQuery, CancellationToken cancellationToken = default(CancellationToken))
+            where TEntity : class, new()
+        {
+            return dataQuery.QuerySingleAsync(ReaderFactory.EntityFactory<TEntity>, cancellationToken);
+        }
+
     }
 }

src/FluentCommand/DataCommandExtensions.cs

@@ -2,6 +2,8 @@
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Common;
+using System.Threading;
+using System.Threading.Tasks;
 using FluentCommand.Extensions;
 
 namespace FluentCommand
@@ -165,5 +167,19 @@ public static TValue QueryValue<TValue>(this IDataQuery dataQuery)
             return dataQuery.QueryValue<TValue>(null);
         }
 
+        /// <summary>
+        /// Executes the query and returns the first column of the first row in the result set returned by the query asynchronously. All other columns and rows are ignored.
+        /// </summary>
+        /// <typeparam name="TValue">The type of the value.</typeparam>
+        /// <param name="dataQuery">The <see cref="IDataQuery"/> for this extension method.</param>
+        /// <param name="cancellationToken">The cancellation instruction.</param>
+        /// <returns>
+        /// The value of the first column of the first row in the result set.
+        /// </returns>
+        public static Task<TValue> QueryValueAsync<TValue>(this IDataQueryAsync dataQuery, CancellationToken cancellationToken = default(CancellationToken))
+        {
+            return dataQuery.QueryValueAsync<TValue>(null, cancellationToken);
+        }
+
     }
 }