API Improvements with test pass.

Fundamental .Excute methods are unchanged.
.Retrieve, .RetrieveAsync, .Results, .ResultsAsync,
.AsSourceBlockAsync, etc...
Are all update to take advantage of the method's intention to the fullest.

Author: electricessence

Documentation.xml

@@ -126,15 +126,54 @@ public Task<List<T>> TakeAsync<T>(Func<IDataRecord, T> transform, int count)
 		/// <returns>The task that completes when the iteration is done or the predicate evaluates false.</returns>
 		public abstract Task IterateReaderAsyncWhile(Func<IDataRecord, Task<bool>> predicate);
 
-		/// <summary>
-		/// Posts all transformed records to the provided target block.
-		/// If .Complete is called on the target block, then the iteration stops.
-		/// </summary>
-		/// <typeparam name="T">The return type of the transform function.</typeparam>
-		/// <param name="transform">The transform function to process each IDataRecord.</param>
-		/// <param name="target">The target block to receive the records.</param>
-		/// <returns>A task that is complete once there are no more results.</returns>
-		public Task ToTargetBlockAsync<T>(ITargetBlock<T> target, Func<IDataRecord, T> transform)
+        /// <summary>
+        /// Asynchronously iterates all records within the first result set using an IDataReader and returns the results.
+        /// </summary>
+        /// <returns>The QueryResult that contains all the results and the column mappings.</returns>
+        public abstract Task<QueryResult<Queue<object[]>>> RetrieveAsync();
+
+        /// <summary>
+        /// Asynchronously iterates all records within the current result set using an IDataReader and returns the desired results.
+        /// </summary>
+        /// <param name="ordinals">The ordinals to request from the reader for each record.</param>
+        /// <returns>The QueryResult that contains all the results and the column mappings.</returns>
+        public abstract Task<QueryResult<Queue<object[]>>> RetrieveAsync(IEnumerable<int> ordinals);
+
+        /// <summary>
+        /// Asynchronously iterates all records within the current result set using an IDataReader and returns the desired results.
+        /// </summary>
+        /// <param name="n">The first ordinal to include in the request to the reader for each record.</param>
+        /// <param name="others">The remaining ordinals to request from the reader for each record.</param>
+        /// <returns>The QueryResult that contains all the results and the column mappings.</returns>
+        public Task<QueryResult<Queue<object[]>>> RetrieveAsync(int n, params int[] others)
+            => RetrieveAsync(new int[1] { n }.Concat(others));
+
+        /// <summary>
+        /// Iterates all records within the first result set using an IDataReader and returns the desired results as a list of Dictionaries containing only the specified column values.
+        /// </summary>
+        /// <param name="columnNames">The column names to select.</param>
+        /// <param name="normalizeColumnOrder">Orders the results arrays by ordinal.</param>
+        /// <returns>The QueryResult that contains all the results and the column mappings.</returns>
+        public abstract Task<QueryResult<Queue<object[]>>> RetrieveAsync(IEnumerable<string> columnNames, bool normalizeColumnOrder = false);
+
+        /// <summary>
+        /// Iterates all records within the current result set using an IDataReader and returns the desired results.
+        /// </summary>
+        /// <param name="c">The first column name to include in the request to the reader for each record.</param>
+        /// <param name="others">The remaining column names to request from the reader for each record.</param>
+        /// <returns>The QueryResult that contains all the results and the column mappings.</returns>
+        public Task<QueryResult<Queue<object[]>>> RetrieveAsync(string c, params string[] others)
+            => RetrieveAsync(new string[1] { c }.Concat(others));
+
+        /// <summary>
+        /// Posts all transformed records to the provided target block.
+        /// If .Complete is called on the target block, then the iteration stops.
+        /// </summary>
+        /// <typeparam name="T">The return type of the transform function.</typeparam>
+        /// <param name="transform">The transform function to process each IDataRecord.</param>
+        /// <param name="target">The target block to receive the records.</param>
+        /// <returns>A task that is complete once there are no more results.</returns>
+        public Task ToTargetBlockAsync<T>(ITargetBlock<T> target, Func<IDataRecord, T> transform)
 		{
 			Task<bool> lastSend = null;
 			return IterateReaderAsyncWhile(async r =>
@@ -169,13 +208,30 @@ public ISourceBlock<T> AsSourceBlockAsync<T>(Func<IDataRecord, T> transform)
 		public abstract ISourceBlock<T> AsSourceBlockAsync<T>(IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides)
 		   where T : new();
 
-
 		/// <summary>
 		/// Asynchronously returns all records via a transform function.
 		/// </summary>
 		/// <param name="transform">The desired column names.</param>
 		/// <returns>A task containing the list of results.</returns>
-		public abstract Task<List<T>> ToListAsync<T>(Func<IDataRecord, T> transform);
+		public async Task<List<T>> ToListAsync<T>(Func<IDataRecord, T> transform)
+        {
+            var results = new List<T>();
+            await IterateReaderAsync(record => results.Add(transform(record)));
+            return results;
+        }
+
+        /// <summary>
+        /// Asynchronously returns all records and iteratively attempts to map the fields to type T.
+        /// </summary>
+		/// <typeparam name="T">The model type to map the values to (using reflection).</typeparam>
+		/// <param name="fieldMappingOverrides">An override map of field names to column names where the keys are the property names, and values are the column names.</param>
+        /// <returns>A task containing the list of results.</returns>
+        public async Task<IEnumerable<T>> ResultsAsync<T>(IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides = null) where T : new()
+        {
+            var x = new Transformer<T>(fieldMappingOverrides);
+            return x.AsDequeueingEnumerable(await RetrieveAsync(x.ColumnNames));
+        }
+
 
-	}
+    }
 }

ExpressiveAsyncCommandBase.cs

@@ -399,15 +399,15 @@ public T[] ToArray<T>(Func<IDataRecord, T> transform)
 		/// <summary>
 		/// Iterates all records within the first result set using an IDataReader and returns the results.
 		/// </summary>
-		/// <returns>the DataReaderResults that contain all the results and the column mappings.</returns>
+		/// <returns>The QueryResult that contains all the results and the column mappings.</returns>
 		public QueryResult<Queue<object[]>> Retrieve()
 			=> Execute(command => command.Retrieve());
 
 		/// <summary>
 		/// Iterates all records within the current result set using an IDataReader and returns the desired results.
 		/// </summary>
 		/// <param name="ordinals">The ordinals to request from the reader for each record.</param>
-		/// <returns>the DataReaderResults that contain all the results and the column mappings.</returns>
+		/// <returns>The QueryResult that contains all the results and the column mappings.</returns>
 		public QueryResult<Queue<object[]>> Retrieve(IEnumerable<int> ordinals)
 			=> Execute(command => command.Retrieve(ordinals));
 
@@ -416,15 +416,15 @@ public QueryResult<Queue<object[]>> Retrieve(IEnumerable<int> ordinals)
 		/// </summary>
 		/// <param name="n">The first ordinal to include in the request to the reader for each record.</param>
 		/// <param name="others">The remaining ordinals to request from the reader for each record.</param>
-		/// <returns>the DataReaderResults that contain all the results and the column mappings.</returns>
+		/// <returns>The QueryResult that contains all the results and the column mappings.</returns>
 		public QueryResult<Queue<object[]>> Retrieve(int n, params int[] others)
 			=> Execute(command => command.Retrieve(n, others));
 
 		/// <summary>
 		/// Iterates all records within the first result set using an IDataReader and returns the desired results as a list of Dictionaries containing only the specified column values.
 		/// </summary>
 		/// <param name="columnNames">The column names to select.</param>
-		/// <returns>the DataReaderResults that contain all the results and the column mappings.</returns>
+		/// <returns>The QueryResult that contains all the results and the column mappings.</returns>
 		public QueryResult<Queue<object[]>> Retrieve(IEnumerable<string> columnNames)
 			=> Execute(command => command.Retrieve(columnNames));
 
@@ -433,7 +433,7 @@ public QueryResult<Queue<object[]>> Retrieve(IEnumerable<string> columnNames)
 		/// </summary>
 		/// <param name="c">The first column name to include in the request to the reader for each record.</param>
 		/// <param name="others">The remaining column names to request from the reader for each record.</param>
-		/// <returns>the DataReaderResults that contain all the results and the column mappings.</returns>
+		/// <returns>The QueryResult that contains all the results and the column mappings.</returns>
 		public QueryResult<Queue<object[]>> Retrieve(string c, params string[] others)
 			=> Execute(command => command.Retrieve(c, others));