Updated ISourceBlock<T> to IReceivableSourceBlock<T>

Author: Oren (electricessence)

Documentation.xml

@@ -776,7 +776,7 @@ public void ToTargetBlock<T>(ITargetBlock<T> target, Func<IDataRecord, T> transf
 		/// If set to true, the command runs synchronously and all data is acquired before the method returns.
 		/// If set to false (default) the data is received asynchronously (deferred: data will be subsequently posted) and the source block (transform) can be completed early.</param>
 		/// <returns>The buffer block that will contain the results.</returns>
-		public ISourceBlock<T> AsSourceBlock<T>(
+		public IReceivableSourceBlock<T> AsSourceBlock<T>(
 			Func<IDataRecord, T> transform,
 			bool synchronousExecution = false)
 		{
@@ -805,7 +805,7 @@ void I()
 		/// If set to false (default) the data is received asynchronously (data will be subsequently posted) and the source block (transform) can be completed early.</param>
 		/// <param name="options">The optional ExecutionDataflowBlockOptions to use with the source.</param>
 		/// <returns>A transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlock<T>(
+		public IReceivableSourceBlock<T> AsSourceBlock<T>(
 			IEnumerable<(string Field, string Column)> fieldMappingOverrides,
 			bool synchronousExecution = false,
 			ExecutionDataflowBlockOptions options = null)
@@ -844,7 +844,7 @@ void I() => ExecuteReader(reader =>
 		/// If set to false (default) the data is received asynchronously (data will be subsequently posted) and the source block (transform) can be completed early.</param>
 		/// <param name="options">The optional ExecutionDataflowBlockOptions to use with the source.</param>
 		/// <returns>A transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlock<T>(
+		public IReceivableSourceBlock<T> AsSourceBlock<T>(
 			IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides,
 			bool synchronousExecution = false,
 			ExecutionDataflowBlockOptions options = null)
@@ -857,7 +857,7 @@ public ISourceBlock<T> AsSourceBlock<T>(
 		/// <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 transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlock<T>(params (string Field, string Column)[] fieldMappingOverrides)
+		public IReceivableSourceBlock<T> AsSourceBlock<T>(params (string Field, string Column)[] fieldMappingOverrides)
 			where T : new()
 			=> AsSourceBlock<T>(fieldMappingOverrides as IEnumerable<(string Field, string Column)>);
 

ExpressiveCommandBase.cs

@@ -416,7 +416,7 @@ public Task ToTargetBlockAsync<T>(ITargetBlock<T> target, Func<IDataRecord, T> t
 		/// <param name="transform">The transform function to process each IDataRecord.</param>
 		/// <param name="options">The optional DataflowBlockOptions to use with the source.</param>
 		/// <returns>A buffer block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlockAsync<T>(
+		public IReceivableSourceBlock<T> AsSourceBlockAsync<T>(
 			Func<IDataRecord, T> transform,
 			DataflowBlockOptions options = null)
 		{
@@ -441,7 +441,7 @@ public ISourceBlock<T> AsSourceBlockAsync<T>(
 		/// <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>
 		/// <param name="options">The optional ExecutionDataflowBlockOptions to use with the source.</param>
 		/// <returns>A transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlockAsync<T>(
+		public IReceivableSourceBlock<T> AsSourceBlockAsync<T>(
 			IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides,
 			ExecutionDataflowBlockOptions options = null)
 		   where T : new()
@@ -453,7 +453,7 @@ public ISourceBlock<T> AsSourceBlockAsync<T>(
 		/// <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 transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlockAsync<T>(params (string Field, string Column)[] fieldMappingOverrides)
+		public IReceivableSourceBlock<T> AsSourceBlockAsync<T>(params (string Field, string Column)[] fieldMappingOverrides)
 		where T : new()
 			=> AsSourceBlockAsync<T>(fieldMappingOverrides as IEnumerable<(string Field, string Column)>);
 
@@ -464,7 +464,7 @@ public ISourceBlock<T> AsSourceBlockAsync<T>(params (string Field, string Column
 		/// <param name="options">The optional ExecutionDataflowBlockOptions to use with the source.</param>
         /// <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 transform block that is receiving the results.</returns>
-        public ISourceBlock<T> AsSourceBlockAsync<T>(
+        public IReceivableSourceBlock<T> AsSourceBlockAsync<T>(
                 ExecutionDataflowBlockOptions options,
                 params (string Field, string Column)[] fieldMappingOverrides)
         where T : new()
@@ -508,7 +508,7 @@ public async Task<List<T>> ToListAsync<T>(Func<IDataRecord, T> transform, Comman
 		/// <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>
 		/// <param name="options"></param>
 		/// <returns>A transform block that is receiving the results.</returns>
-		public ISourceBlock<T> AsSourceBlockAsync<T>(
+		public IReceivableSourceBlock<T> AsSourceBlockAsync<T>(
 			IEnumerable<(string Field, string Column)> fieldMappingOverrides,
 			ExecutionDataflowBlockOptions options = null)
 			where T : new()

ExpressiveDbCommandBase.cs

@@ -11,7 +11,7 @@
     <Description>Useful set of utilities and abstractions for simplifying modern data-access operations and ensuring DI compatibility.</Description>
     <RepositoryUrl>https://github.com/electricessence/Open.Database.Extensions</RepositoryUrl>
     <RepositoryType>git</RepositoryType>
-    <Version>5.13.1</Version>
+    <Version>5.13.2</Version>
     <AssemblyVersion>5.13.0.0</AssemblyVersion>
     <FileVersion>5.13.0.0</FileVersion>
     <PackageReleaseNotes>Cleanup and inspection fixes with added Dataflow options.

Open.Database.Extensions.csproj

@@ -143,7 +143,7 @@ public static Task<IEnumerable<T>> DequeueAs<T>(this Task<QueryResult<Queue<obje
 		/// </summary>
 		/// <param name="source">The query result.  Typically produced by a .Retrieve method.</param>
 		/// <returns>An block that dequeues the results and returns a column mapped dictionary for each entry</returns>
-		public static ISourceBlock<Dictionary<string, object>> AsMappedDictionaries(this QueryResult<ISourceBlock<object[]>> source)
+		public static IReceivableSourceBlock<Dictionary<string, object>> AsMappedDictionaries(this QueryResult<IReceivableSourceBlock<object[]>> source)
 		{
 			var q = source.Result;
 			var names = source.Names;
@@ -170,8 +170,8 @@ public static ISourceBlock<Dictionary<string, object>> AsMappedDictionaries(this
 		/// <param name="fieldMappingOverrides">An optional override map of field names to column names where the keys are the property names, and values are the column names.</param>
 		/// <param name="options">The ExecutionDataflowBlockOptions for transforming the data into the source block.</param>
 		/// <returns>An block that dequeues the results and returns a column mapped dictionary for each entry</returns>
-		public static ISourceBlock<T> To<T>(
-			this QueryResult<ISourceBlock<object[]>> source,
+		public static IReceivableSourceBlock<T> To<T>(
+			this QueryResult<IReceivableSourceBlock<object[]>> source,
 			IEnumerable<(string Field, string Column)> fieldMappingOverrides,
 			ExecutionDataflowBlockOptions options = null)
 			where T : new()
@@ -187,7 +187,7 @@ public static ISourceBlock<T> To<T>(
 		/// <param name="source">The query result.  Typically produced by a .Retrieve method.</param>
 		/// <param name="fieldMappingOverrides">An optional override map of field names to column names where the keys are the property names, and values are the column names.</param>
 		/// <returns>An block that dequeues the results and returns a column mapped dictionary for each entry</returns>
-		public static ISourceBlock<T> To<T>(this QueryResult<ISourceBlock<object[]>> source, IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides)
+		public static IReceivableSourceBlock<T> To<T>(this QueryResult<IReceivableSourceBlock<object[]>> source, IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides)
 			where T : new()
 			=> To<T>(source, fieldMappingOverrides?.Select(kvp => (kvp.Key, kvp.Value)));
 
@@ -198,7 +198,7 @@ public static ISourceBlock<T> To<T>(this QueryResult<ISourceBlock<object[]>> sou
 		/// <param name="source">The query result.  Typically produced by a .Retrieve method.</param>
 		/// <param name="fieldMappingOverrides">An optional override map of field names to column names where the keys are the property names, and values are the column names.</param>
 		/// <returns>An block that dequeues the results and returns a column mapped dictionary for each entry</returns>
-		public static ISourceBlock<T> To<T>(this QueryResult<ISourceBlock<object[]>> source, params (string Field, string Column)[] fieldMappingOverrides)
+		public static IReceivableSourceBlock<T> To<T>(this QueryResult<IReceivableSourceBlock<object[]>> source, params (string Field, string Column)[] fieldMappingOverrides)
 			where T : new()
 			=> To<T>(source, fieldMappingOverrides as IEnumerable<(string Field, string Column)>);
 

QueryResult.cs

@@ -111,7 +111,7 @@ public IEnumerable<T> AsDequeueingEnumerable(QueryResult<Queue<object[]>> result
 			// By using the above routine, we guarantee as enumeration occurs, references are released (dequeued).
 		}
 
-		public ISourceBlock<T> Results(
+		public IReceivableSourceBlock<T> Results(
 			out Action<QueryResult<IEnumerable<object[]>>> deferred,
 			ExecutionDataflowBlockOptions options = null)
 		{
@@ -129,8 +129,8 @@ public ISourceBlock<T> Results(
 			return x;
 		}
 
-		public ISourceBlock<T> Results(
-			QueryResult<ISourceBlock<object[]>> source,
+		public IReceivableSourceBlock<T> Results(
+			QueryResult<IReceivableSourceBlock<object[]>> source,
 			ExecutionDataflowBlockOptions options = null)
 		{
 			var processor = new Processor(this, source.Names);