2020 年 3 月更新
.NET Core 3.0（和 3.1）现已发布，完全支持异步流。 Microsoft.Bcl.AsyncInterfaces 为 .NET Standard 2.0 和 .NET Framework 4.6.1+ 添加了对它们的支持，尽管出于理智的原因应该使用 4.7.2。作为.NET Standard implementation support explain上的文档
虽然 NuGet 认为 .NET Framework 4.6.1 支持 .NET Standard 1.5 到 2.0，但使用为 .NET Framework 4.6.1 项目中的这些版本构建的 .NET Standard 库存在几个问题。
对于需要使用此类库的 .NET Framework 项目，我们建议您将项目升级到面向 .NET Framework 4.7.2 或更高版本。
原答案
如果您check the source code，您会发现您的怀疑几乎是正确的。当buffered 为假时，QueryAsync 将同步流式传输。
if (command.Buffered)
{
var buffer = new List<T>();
var convertToType = Nullable.GetUnderlyingType(effectiveType) ?? effectiveType;
while (await reader.ReadAsync(cancel).ConfigureAwait(false))
{
object val = func(reader);
if (val == null || val is T)
{
buffer.Add((T)val);
}
else
{
buffer.Add((T)Convert.ChangeType(val, convertToType, CultureInfo.InvariantCulture));
}
}
while (await reader.NextResultAsync(cancel).ConfigureAwait(false)) { /* ignore subsequent result sets */ }
command.OnCompleted();
return buffer;
}
else
{
// can't use ReadAsync / cancellation; but this will have to do
wasClosed = false; // don't close if handing back an open reader; rely on the command-behavior
var deferred = ExecuteReaderSync<T>(reader, func, command.Parameters);
reader = null; // to prevent it being disposed before the caller gets to see it
return deferred;
}
正如评论所解释的，当预期返回类型为 IEnumerable 时，无法使用 ReadAsync。这就是为什么必须引入 C# 8 的异步枚举的原因。
ExecuteReaderSync 的代码是：
private static IEnumerable<T> ExecuteReaderSync<T>(IDataReader reader, Func<IDataReader, object> func, object parameters)
{
using (reader)
{
while (reader.Read())
{
yield return (T)func(reader);
}
while (reader.NextResult()) { /* ignore subsequent result sets */ }
(parameters as IParameterCallbacks)?.OnCompleted();
}
}
它使用Read 而不是ReadAsync。
C#8 异步流将允许重写它以返回 IAsyncEnumerable。仅仅更改语言版本并不能解决问题。
鉴于当前有关异步流的文档，这可能看起来像：
private static async IAsyncEnumerable<T> ExecuteReaderASync<T>(IDataReader reader, Func<IDataReader, object> func, object parameters)
{
using (reader)
{
while (await reader.ReadAsync())
{
yield return (T)func(reader);
}
while (await reader.NextResultAsync(cancel).ConfigureAwait(false)) { /* ignore subsequent result sets */ }
command.OnCompleted();
(parameters as IParameterCallbacks)?.OnCompleted();
}
}
Buuuuuut 异步流是只能在 .NET Core 上工作的东西之一，可能还没有实现。当我尝试在 Sharplab.io 中写一个时，Kaboom。 [connection lost, reconnecting…]