如何使用 StreamReader.ReadAsync(Memory<Char>, CancellationToken)

Question

我正在尝试使用接受Memory<T> 的StreamReader.ReadAsync(Memory, CancellationToken) overload。 以下是示例代码：(.NET Core 2.1)

static async Task Main(string[] args)
{
    string code = "Hello, World";
    var memoryStream = Encoding.UTF8.GetBytes(code.ToCharArray(), 0, code.Length);
    using (var stream = new MemoryStream(memoryStream))
    using (var reader = new StreamReader(stream))
    {
        // var text = await reader.ReadLineAsync();
        // Console.WriteLine(text); -> Outputs: Hello, World

        Memory<char> memory = new Memory<char>();
        await reader.ReadAsync(memory);

        Console.WriteLine("Memory<char> length:" + memory.Length);
    }

}

代码尝试通过StreamReader 读取字符串内容并填充Memory<char>。但是，对于 Memory<char> 长度，代码一直输出 0。

使用此方法填充Memory<char> 的正确方法是什么？

我的.csproj文件内容：

<Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp2.1</TargetFramework>
    <LangVersion>7.2</LangVersion>
  </PropertyGroup>
</Project>

Answer 1

可行的解决方案是使用缓冲区初始化内存并注意 ReadAsync 的返回值，以便您知道您读取了多少个字符（而不是字节）。

您确实遇到了 Memory 是一个结构体的问题，它始终允许您创建不带参数的实例，尽管从 API 使用的角度来看这是不允许的。

using System;
using System.IO;
using System.Text;
using System.Threading.Tasks;

namespace ReadMemory
{
    class Program
    {
        public static async Task Main(string[] args)
        {
            string code = "Hello, World";
            var memoryStream = Encoding.UTF8.GetBytes(code.ToCharArray(), 0, code.Length);
            using (var stream = new MemoryStream(memoryStream))
            using (var reader = new StreamReader(stream))
            {

                Memory<char> memory = new Memory<char>(new char[1024]);  // Init with backing buffer. Otherwise you are trying to read 0 bytes into a zero sized buffer. 
                int charsRead = await reader.ReadAsync(memory);

                Console.WriteLine($"Memory<char> len: {memory.Length}, bytes read: {charsRead}");
            }

        }
    }
}

回答你第二个问题。是的，您可以使用 ReadAsync(char[] ...) 代替内存。它们是等效的，因为在引擎盖下它作为 System.Memory 被进一步传递，然后当涉及到实际读数转换为 Span 时。 见

public virtual System.Threading.Tasks.Task<int> ReadAsync(char[] buffer, int index, int count)
{
    return this.ReadAsyncInternal(new Memory<char>(buffer, index, count), default(System.Threading.CancellationToken)).AsTask();
}