Class DataflowExtensions

Namespace: Open.Database.Extensions

Assembly: Open.Database.Extensions.Dataflow.dll

Extensions for pipelining data with Dataflow blocks.

[SuppressMessage("Reliability", "CA2012:Use ValueTasks correctly", Justification = "Intentionally running in the background.")]
[SuppressMessage("Roslynator", "RCS1047:Non-asynchronous method name should not end with 'Async'.", Justification = "<Pending>")]
public static class DataflowExtensions

Inheritance: object

DataflowExtensions

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

AsSourceBlock(IExecuteReader, ArrayPool<object>, DataflowBlockOptions?): Reads the results of an IExecuteReader to the end, posting each record as an array of values rented from an array pool to a new BufferBlock<T>, and returns the block.

AsSourceBlock(IExecuteReader, DataflowBlockOptions?): Reads the results of an IExecuteReader to the end, posting each record as an array of values to a new BufferBlock<T>, and returns the block.

AsSourceBlock(IDataReader, ArrayPool<object>, DataflowBlockOptions?): Reads an IDataReader to the end, posting each record as an array of values rented from an array pool to a new BufferBlock<T>, and returns the block.

AsSourceBlock(IDataReader, DataflowBlockOptions?): Reads an IDataReader to the end, posting each record as an array of values to a new BufferBlock<T>, and returns the block.

AsSourceBlock(IDbCommand, ArrayPool<object>, DataflowBlockOptions?): Reads the results of an IDbCommand to the end, posting each record as an array of values rented from an array pool to a new BufferBlock<T>, and returns the block.

AsSourceBlock(IDbCommand, DataflowBlockOptions?): Reads the results of an IDbCommand to the end, posting each record as an array of values to a new BufferBlock<T>, and returns the block.

AsSourceBlockAsync(IExecuteReader, ArrayPool<object>, DataflowBlockOptions?): Starts reading the results of an IExecuteReader in the background and returns a new BufferBlock<T> that receives each record as an array of values rented from an array pool as it is read.

AsSourceBlockAsync(IExecuteReader, DataflowBlockOptions?): Starts reading the results of an IExecuteReader in the background and returns a new BufferBlock<T> that receives each record as an array of values as it is read.

AsSourceBlockAsync(IDataReader, ArrayPool<object>, DataflowBlockOptions?, CancellationToken): Starts reading an IDataReader in the background and returns a new BufferBlock<T> that receives each record as an array of values rented from an array pool as it is read.

AsSourceBlockAsync(IDataReader, DataflowBlockOptions?, CancellationToken): Starts reading an IDataReader in the background and returns a new BufferBlock<T> that receives each record as an array of values as it is read.

AsSourceBlockAsync(IDbCommand, ArrayPool<object>, DataflowBlockOptions?, CancellationToken): Starts reading the results of an IDbCommand in the background and returns a new BufferBlock<T> that receives each record as an array of values rented from an array pool as it is read.

AsSourceBlockAsync(IDbCommand, DataflowBlockOptions?, CancellationToken): Starts reading the results of an IDbCommand in the background and returns a new BufferBlock<T> that receives each record as an array of values as it is read.

AsSourceBlockAsync<T>(IExecuteReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?): Starts reading the results of an IExecuteReader in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T, using the field-to-column overrides as it is read.

AsSourceBlockAsync<T>(IExecuteReader, Func<IDataRecord, T>, DataflowBlockOptions?): Starts reading the results of an IExecuteReader in the background and returns a new BufferBlock<T> that receives each record after it has been transformed by transform as it is read.

AsSourceBlockAsync<T>(IExecuteReader, DataflowBlockOptions?): Starts reading the results of an IExecuteReader in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T as it is read.

AsSourceBlockAsync<T>(IDataReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?, CancellationToken): Starts reading an IDataReader in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T, using the field-to-column overrides as it is read.

AsSourceBlockAsync<T>(IDataReader, Func<IDataRecord, T>, DataflowBlockOptions?, CancellationToken): Starts reading an IDataReader in the background and returns a new BufferBlock<T> that receives each record after it has been transformed by transform as it is read.

AsSourceBlockAsync<T>(IDataReader, DataflowBlockOptions?, CancellationToken): Starts reading an IDataReader in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T as it is read.

AsSourceBlockAsync<T>(IDbCommand, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?, CancellationToken): Starts reading the results of an IDbCommand in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T, using the field-to-column overrides as it is read.

AsSourceBlockAsync<T>(IDbCommand, Func<IDataRecord, T>, DataflowBlockOptions?, CancellationToken): Starts reading the results of an IDbCommand in the background and returns a new BufferBlock<T> that receives each record after it has been transformed by transform as it is read.

AsSourceBlockAsync<T>(IDbCommand, DataflowBlockOptions?, CancellationToken): Starts reading the results of an IDbCommand in the background and returns a new BufferBlock<T> that receives each record mapped to a new instance of T as it is read.

AsSourceBlock<T>(IExecuteReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?): Reads the results of an IExecuteReader to the end, posting each record mapped to a new instance of T, using the field-to-column overrides to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IExecuteReader, Func<IDataRecord, T>, DataflowBlockOptions?): Reads the results of an IExecuteReader to the end, posting each record after it has been transformed by transform to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IExecuteReader, DataflowBlockOptions?): Reads the results of an IExecuteReader to the end, posting each record mapped to a new instance of T to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDataReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?): Reads an IDataReader to the end, posting each record mapped to a new instance of T, using the field-to-column overrides to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDataReader, Func<IDataRecord, T>, DataflowBlockOptions?): Reads an IDataReader to the end, posting each record after it has been transformed by transform to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDataReader, DataflowBlockOptions?): Reads an IDataReader to the end, posting each record mapped to a new instance of T to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDbCommand, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?): Reads the results of an IDbCommand to the end, posting each record mapped to a new instance of T, using the field-to-column overrides to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDbCommand, Func<IDataRecord, T>, DataflowBlockOptions?): Reads the results of an IDbCommand to the end, posting each record after it has been transformed by transform to a new BufferBlock<T>, and returns the block.

AsSourceBlock<T>(IDbCommand, DataflowBlockOptions?): Reads the results of an IDbCommand to the end, posting each record mapped to a new instance of T to a new BufferBlock<T>, and returns the block.

ToTargetBlock(IExecuteReader, ITargetBlock<object[]>, bool): Reads the results of an IExecuteReader, posting each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlock(IExecuteReader, ITargetBlock<object[]>, bool, ArrayPool<object>): Reads the results of an IExecuteReader, posting each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlock(IDataReader, ITargetBlock<object[]>, bool): Reads an IDataReader, posting each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlock(IDataReader, ITargetBlock<object[]>, bool, ArrayPool<object>): Reads an IDataReader, posting each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlock(IDbCommand, ITargetBlock<object[]>, bool): Reads the results of an IDbCommand, posting each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlock(IDbCommand, ITargetBlock<object[]>, bool, ArrayPool<object>): Reads the results of an IDbCommand, posting each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IExecuteReader, ITargetBlock<object[]>, bool): Asynchronously reads the results of an IExecuteReader, sending each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IExecuteReader, ITargetBlock<object[]>, bool, ArrayPool<object>): Asynchronously reads the results of an IExecuteReader, sending each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IDataReader, ITargetBlock<object[]>, bool, ArrayPool<object>, CancellationToken): Asynchronously reads an IDataReader, sending each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IDataReader, ITargetBlock<object[]>, bool, CancellationToken): Asynchronously reads an IDataReader, sending each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IDbCommand, ITargetBlock<object[]>, bool, ArrayPool<object>, CancellationToken): Asynchronously reads the results of an IDbCommand, sending each record as an array of values rented from an array pool to the target block, and stops when the target declines a record.

ToTargetBlockAsync(IDbCommand, ITargetBlock<object[]>, bool, CancellationToken): Asynchronously reads the results of an IDbCommand, sending each record as an array of values to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool): Asynchronously reads the results of an IExecuteReader, sending each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>): Asynchronously reads the results of an IExecuteReader, sending each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool, Func<IDataRecord, T>): Asynchronously reads the results of an IExecuteReader, sending each record after it has been transformed by transform to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDataReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Asynchronously reads an IDataReader, sending each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDataReader, ITargetBlock<T>, bool, Func<IDataRecord, T>, CancellationToken): Asynchronously reads an IDataReader, sending each record after it has been transformed by transform to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDataReader, ITargetBlock<T>, bool, CancellationToken): Asynchronously reads an IDataReader, sending each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDbCommand, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Asynchronously reads the results of an IDbCommand, sending each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDbCommand, ITargetBlock<T>, bool, Func<IDataRecord, T>, CancellationToken): Asynchronously reads the results of an IDbCommand, sending each record after it has been transformed by transform to the target block, and stops when the target declines a record.

ToTargetBlockAsync<T>(IDbCommand, ITargetBlock<T>, bool, CancellationToken): Asynchronously reads the results of an IDbCommand, sending each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool): Reads the results of an IExecuteReader, posting each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>): Reads the results of an IExecuteReader, posting each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool, Func<IDataRecord, T>): Reads the results of an IExecuteReader, posting each record after it has been transformed by transform to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDataReader, ITargetBlock<T>, bool): Reads an IDataReader, posting each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDataReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>): Reads an IDataReader, posting each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDataReader, ITargetBlock<T>, bool, Func<IDataRecord, T>): Reads an IDataReader, posting each record after it has been transformed by transform to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDbCommand, ITargetBlock<T>, bool): Reads the results of an IDbCommand, posting each record mapped to a new instance of T to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDbCommand, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>): Reads the results of an IDbCommand, posting each record mapped to a new instance of T, using the field-to-column overrides to the target block, and stops when the target declines a record.

ToTargetBlock<T>(IDbCommand, ITargetBlock<T>, bool, Func<IDataRecord, T>): Reads the results of an IDbCommand, posting each record after it has been transformed by transform to the target block, and stops when the target declines a record.

Edit this page