Class ChannelDbExtensions

Namespace: Open.Database.Extensions

Assembly: Open.Database.Extensions.Channel.dll

Extensions for writing data to a channel.

[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>")]
[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Simplification and readability.")]
public static class ChannelDbExtensions

Inheritance: object

ChannelDbExtensions

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ToChannel(IExecuteReader, bool): Starts reading the results of an IExecuteReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannel(IExecuteReader, bool, ArrayPool<object>): Starts reading the results of an IExecuteReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannel(IExecuteReader, ChannelWriter<object[]>, bool): Iterates the results of an IExecuteReader and writes each record as an array of values to the target channel.

ToChannel(IExecuteReader, ChannelWriter<object[]>, bool, ArrayPool<object>): Iterates the results of an IExecuteReader and writes each record as an array of values rented from an array pool to the target channel.

ToChannel(IDataReader, bool, ArrayPool<object>?, CancellationToken): Starts reading an IDataReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannel(IDataReader, bool, CancellationToken): Starts reading an IDataReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannel(IDataReader, ChannelWriter<object[]>, bool, ArrayPool<object>?, CancellationToken): Iterates an IDataReader and writes each record as an array of values rented from an array pool to the target channel.

ToChannel(IDataReader, ChannelWriter<object[]>, bool, CancellationToken): Iterates an IDataReader and writes each record as an array of values to the target channel.

ToChannel(IDbCommand, bool, ArrayPool<object>, CancellationToken): Starts reading the results of an IDbCommand in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannel(IDbCommand, bool, CancellationToken): Starts reading the results of an IDbCommand in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannel(IDbCommand, ChannelWriter<object[]>, bool, ArrayPool<object>, CancellationToken): Iterates the results of an IDbCommand and writes each record as an array of values rented from an array pool to the target channel.

ToChannel(IDbCommand, ChannelWriter<object[]>, bool, CancellationToken): Iterates the results of an IDbCommand and writes each record as an array of values to the target channel.

ToChannelAsync(IExecuteReaderAsync, bool): Starts asynchronously reading the results of an IExecuteReaderAsync in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannelAsync(IExecuteReaderAsync, bool, ArrayPool<object>?): Starts asynchronously reading the results of an IExecuteReaderAsync in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannelAsync(IExecuteReaderAsync, ChannelWriter<object[]>, bool): Asynchronously iterates the results of an IExecuteReaderAsync and writes each record as an array of values to the target channel.

ToChannelAsync(IExecuteReaderAsync, ChannelWriter<object[]>, bool, ArrayPool<object>?): Asynchronously iterates the results of an IExecuteReaderAsync and writes each record as an array of values rented from an array pool to the target channel.

ToChannelAsync(DbCommand, bool, ArrayPool<object>, CancellationToken): Starts asynchronously reading the results of a DbCommand in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannelAsync(DbCommand, bool, CancellationToken): Starts asynchronously reading the results of a DbCommand in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannelAsync(DbCommand, ChannelWriter<object[]>, bool, ArrayPool<object>, CancellationToken): Asynchronously iterates the results of a DbCommand and writes each record as an array of values rented from an array pool to the target channel.

ToChannelAsync(DbCommand, ChannelWriter<object[]>, bool, CancellationToken): Asynchronously iterates the results of a DbCommand and writes each record as an array of values to the target channel.

ToChannelAsync(DbDataReader, bool, ArrayPool<object>, CancellationToken): Starts asynchronously reading a DbDataReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values rented from an array pool.

ToChannelAsync(DbDataReader, bool, CancellationToken): Starts asynchronously reading a DbDataReader in the background and returns the reader of a new unbounded channel that receives each record as an array of values.

ToChannelAsync(DbDataReader, ChannelWriter<object[]>, bool, ArrayPool<object>?, CancellationToken): Asynchronously iterates a DbDataReader and writes each record as an array of values rented from an array pool to the target channel.

ToChannelAsync(DbDataReader, ChannelWriter<object[]>, bool, CancellationToken): Asynchronously iterates a DbDataReader and writes each record as an array of values to the target channel.

ToChannelAsync<T>(IExecuteReaderAsync, bool): Starts asynchronously reading the results of an IExecuteReaderAsync in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannelAsync<T>(IExecuteReaderAsync, bool, IEnumerable<(string Field, string? Column)>): Starts asynchronously reading the results of an IExecuteReaderAsync in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannelAsync<T>(IExecuteReaderAsync, bool, Func<IDataRecord, T>): Starts asynchronously reading the results of an IExecuteReaderAsync in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool): Asynchronously iterates the results of an IExecuteReaderAsync and writes each record mapped to a new instance of T to the target channel.

ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>): Asynchronously iterates the results of an IExecuteReaderAsync and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool, Func<IDataRecord, T>): Asynchronously iterates the results of an IExecuteReaderAsync and writes each record after it has been transformed by transform to the target channel.

ToChannelAsync<T>(DbCommand, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Starts asynchronously reading the results of a DbCommand in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannelAsync<T>(DbCommand, bool, Func<IDataRecord, T>, CancellationToken): Starts asynchronously reading the results of a DbCommand in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannelAsync<T>(DbCommand, bool, CancellationToken): Starts asynchronously reading the results of a DbCommand in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannelAsync<T>(DbCommand, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Asynchronously iterates the results of a DbCommand and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannelAsync<T>(DbCommand, ChannelWriter<T>, bool, Func<IDataRecord, T>, CancellationToken): Asynchronously iterates the results of a DbCommand and writes each record after it has been transformed by transform to the target channel.

ToChannelAsync<T>(DbCommand, ChannelWriter<T>, bool, CancellationToken): Asynchronously iterates the results of a DbCommand and writes each record mapped to a new instance of T to the target channel.

ToChannelAsync<T>(DbDataReader, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Starts asynchronously reading a DbDataReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannelAsync<T>(DbDataReader, bool, Func<IDataRecord, T>, CancellationToken): Starts asynchronously reading a DbDataReader in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannelAsync<T>(DbDataReader, bool, CancellationToken): Starts asynchronously reading a DbDataReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannelAsync<T>(DbDataReader, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Asynchronously iterates a DbDataReader and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannelAsync<T>(DbDataReader, ChannelWriter<T>, bool, Func<IDataRecord, T>, CancellationToken): Asynchronously iterates a DbDataReader and writes each record after it has been transformed by transform to the target channel.

ToChannelAsync<T>(DbDataReader, ChannelWriter<T>, bool, CancellationToken): Asynchronously iterates a DbDataReader and writes each record mapped to a new instance of T to the target channel.

ToChannel<T>(IExecuteReader, bool): Starts reading the results of an IExecuteReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannel<T>(IExecuteReader, bool, IEnumerable<(string Field, string? Column)>): Starts reading the results of an IExecuteReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannel<T>(IExecuteReader, bool, Func<IDataRecord, T>): Starts reading the results of an IExecuteReader in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool): Iterates the results of an IExecuteReader and writes each record mapped to a new instance of T to the target channel.

ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>): Iterates the results of an IExecuteReader and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool, Func<IDataRecord, T>): Iterates the results of an IExecuteReader and writes each record after it has been transformed by transform to the target channel.

ToChannel<T>(IDataReader, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Starts reading an IDataReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannel<T>(IDataReader, bool, Func<IDataRecord, T>, CancellationToken): Starts reading an IDataReader in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannel<T>(IDataReader, bool, CancellationToken): Starts reading an IDataReader in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannel<T>(IDataReader, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Iterates an IDataReader and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannel<T>(IDataReader, ChannelWriter<T>, bool, Func<IDataRecord, T>, CancellationToken): Iterates an IDataReader and writes each record after it has been transformed by transform to the target channel.

ToChannel<T>(IDataReader, ChannelWriter<T>, bool, CancellationToken): Iterates an IDataReader and writes each record mapped to a new instance of T to the target channel.

ToChannel<T>(IDbCommand, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Starts reading the results of an IDbCommand in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T, using the field-to-column overrides.

ToChannel<T>(IDbCommand, bool, Func<IDataRecord, T>, CancellationToken): Starts reading the results of an IDbCommand in the background and returns the reader of a new unbounded channel that receives each record after it has been transformed by transform.

ToChannel<T>(IDbCommand, bool, CancellationToken): Starts reading the results of an IDbCommand in the background and returns the reader of a new unbounded channel that receives each record mapped to a new instance of T.

ToChannel<T>(IDbCommand, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>, CancellationToken): Iterates the results of an IDbCommand and writes each record mapped to a new instance of T, using the field-to-column overrides to the target channel.

ToChannel<T>(IDbCommand, ChannelWriter<T>, bool, Func<IDataRecord, T>, CancellationToken): Iterates the results of an IDbCommand and writes each record after it has been transformed by transform to the target channel.

ToChannel<T>(IDbCommand, ChannelWriter<T>, bool, CancellationToken): Iterates the results of an IDbCommand and writes each record mapped to a new instance of T to the target channel.

Table of Contents

Class ChannelDbExtensions

Methods