Interface IExecuteReaderAsync

Namespace

Open.Database.Extensions

Assembly

Open.Database.Extensions.Core.dll

Common interface used for expressive commands when dealing with a data reader.

public interface IExecuteReaderAsync : IExecuteReader

Inherited Members

IExecuteReader.CancellationToken

IExecuteReader.ExecuteReader(Action<IDataReader>, CommandBehavior)

IExecuteReader.ExecuteReader<T>(Func<IDataReader, T>, CommandBehavior)

IExecuteReader.ExecuteReaderAsync(Func<IDataReader, ValueTask>, CommandBehavior)

IExecuteReader.ExecuteReaderAsync<T>(Func<IDataReader, ValueTask<T>>, CommandBehavior)

IExecuteReader.ExecuteReader<TState, TResult>(TState, Func<IDataReader, TState, TResult>, CommandBehavior)

IExecuteReader.ExecuteReaderAsync<TState, TResult>(TState, Func<IDataReader, TState, ValueTask<TResult>>, CommandBehavior)

Extension Methods

ChannelDbExtensions.ToChannel(IExecuteReader, bool)

ChannelDbExtensions.ToChannel(IExecuteReader, bool, ArrayPool<object>)

ChannelDbExtensions.ToChannel(IExecuteReader, ChannelWriter<object[]>, bool)

ChannelDbExtensions.ToChannel(IExecuteReader, ChannelWriter<object[]>, bool, ArrayPool<object>)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, bool)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, bool, IEnumerable<(string Field, string? Column)>)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, bool, Func<IDataRecord, T>)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>)

ChannelDbExtensions.ToChannel<T>(IExecuteReader, ChannelWriter<T>, bool, Func<IDataRecord, T>)

CoreExtensions.Map<T>(IExecuteReader)

CoreExtensions.Map<T>(IExecuteReader, params IEnumerable<KeyValuePair<string, string?>>?)

CoreExtensions.Map<T>(IExecuteReader, params IEnumerable<(string Field, string? Column)>?)

CoreExtensions.Map<T>(IExecuteReader, Func<IDataRecord, T>)

DataflowExtensions.AsSourceBlock(IExecuteReader, ArrayPool<object>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlock(IExecuteReader, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlockAsync(IExecuteReader, ArrayPool<object>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlockAsync(IExecuteReader, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlockAsync<T>(IExecuteReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlockAsync<T>(IExecuteReader, Func<IDataRecord, T>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlockAsync<T>(IExecuteReader, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlock<T>(IExecuteReader, IEnumerable<(string Field, string? Column)>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlock<T>(IExecuteReader, Func<IDataRecord, T>, DataflowBlockOptions?)

DataflowExtensions.AsSourceBlock<T>(IExecuteReader, DataflowBlockOptions?)

DataflowExtensions.ToTargetBlock(IExecuteReader, ITargetBlock<object[]>, bool)

DataflowExtensions.ToTargetBlock(IExecuteReader, ITargetBlock<object[]>, bool, ArrayPool<object>)

DataflowExtensions.ToTargetBlockAsync(IExecuteReader, ITargetBlock<object[]>, bool)

DataflowExtensions.ToTargetBlockAsync(IExecuteReader, ITargetBlock<object[]>, bool, ArrayPool<object>)

DataflowExtensions.ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool)

DataflowExtensions.ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>)

DataflowExtensions.ToTargetBlockAsync<T>(IExecuteReader, ITargetBlock<T>, bool, Func<IDataRecord, T>)

DataflowExtensions.ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool)

DataflowExtensions.ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool, IEnumerable<(string Field, string? Column)>)

DataflowExtensions.ToTargetBlock<T>(IExecuteReader, ITargetBlock<T>, bool, Func<IDataRecord, T>)

IExecuteReaderExtensions.FirstOrDefault<T>(IExecuteReader, Func<IDataRecord, T>)

IExecuteReaderExtensions.FirstOrdinalResults(IExecuteReader)

IExecuteReaderExtensions.FirstOrdinalResults<T0>(IExecuteReader)

IExecuteReaderExtensions.First<T>(IExecuteReader, Func<IDataRecord, T>)

IExecuteReaderExtensions.IterateReader(IExecuteReader, Action<IDataRecord>, CommandBehavior)

IExecuteReaderExtensions.IterateReaderWhile(IExecuteReader, Func<IDataRecord, bool>, CommandBehavior)

IExecuteReaderExtensions.IterateReader<TEntity, TResult>(IExecuteReader, Func<IDataRecord, TEntity>, Func<IEnumerable<TEntity>, TResult>, CommandBehavior)

IExecuteReaderExtensions.LoadTable(IExecuteReader)

IExecuteReaderExtensions.LoadTables(IExecuteReader)

IExecuteReaderExtensions.Results<T>(IExecuteReader, IEnumerable<KeyValuePair<string, string?>>)

IExecuteReaderExtensions.Results<T>(IExecuteReader, IEnumerable<(string Field, string? Column)>)

IExecuteReaderExtensions.Results<T>(IExecuteReader, params (string Field, string? Column)[])

IExecuteReaderExtensions.Retrieve(IExecuteReader)

IExecuteReaderExtensions.Retrieve(IExecuteReader, IEnumerable<int>)

IExecuteReaderExtensions.Retrieve(IExecuteReader, IEnumerable<string>)

IExecuteReaderExtensions.Retrieve(IExecuteReader, int, params IEnumerable<int>)

IExecuteReaderExtensions.Retrieve(IExecuteReader, string, params IEnumerable<string>)

IExecuteReaderExtensions.SingleOrDefault<T>(IExecuteReader, Func<IDataRecord, T>)

IExecuteReaderExtensions.Single<T>(IExecuteReader, Func<IDataRecord, T>)

IExecuteReaderExtensions.SkipThenTake<T>(IExecuteReader, int, int, Func<IDataRecord, T>)

IExecuteReaderExtensions.Skip<T>(IExecuteReader, int, Func<IDataRecord, T>)

IExecuteReaderExtensions.Take<T>(IExecuteReader, int, Func<IDataRecord, T>)

IExecuteReaderExtensions.ToArray<T>(IExecuteReader, Func<IDataRecord, T>, CommandBehavior)

IExecuteReaderExtensions.ToImmutableArray<T>(IExecuteReader, Func<IDataRecord, T>, CommandBehavior)

IExecuteReaderExtensions.ToList<T>(IExecuteReader, Func<IDataRecord, T>, CommandBehavior)

ChannelDbExtensions.ToChannelAsync(IExecuteReaderAsync, bool)

ChannelDbExtensions.ToChannelAsync(IExecuteReaderAsync, bool, ArrayPool<object>?)

ChannelDbExtensions.ToChannelAsync(IExecuteReaderAsync, ChannelWriter<object[]>, bool)

ChannelDbExtensions.ToChannelAsync(IExecuteReaderAsync, ChannelWriter<object[]>, bool, ArrayPool<object>?)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, bool)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, bool, IEnumerable<(string Field, string? Column)>)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, bool, Func<IDataRecord, T>)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool, IEnumerable<(string Field, string? Column)>)

ChannelDbExtensions.ToChannelAsync<T>(IExecuteReaderAsync, ChannelWriter<T>, bool, Func<IDataRecord, T>)

IExecuteReaderExtensions.IterateReaderAsync(IExecuteReaderAsync, Action<IDataRecord>, CommandBehavior)

IExecuteReaderExtensions.IterateReaderWhileAsync(IExecuteReaderAsync, Func<IDataRecord, bool>, CommandBehavior)

IExecuteReaderExtensions.IterateReaderWhileAsync(IExecuteReaderAsync, Func<IDataRecord, ValueTask<bool>>, CommandBehavior)

Properties

UseAsyncRead

Indicates if reader.ReadAsync() will be used in favor of reader.Read().