使用 IAsyncEnumerable 通过 HTTP 通过 Blazor 流式传输文本行

Question

我想将任意数量的纯文本行从 ASP.NET 服务器流式传输到 Blazor WebAssembly 客户端 (.NET 6.0)。

为了测试，我实现了以下虚拟 API：

[HttpGet("lines")]
public async IAsyncEnumerable<string> GetLines() {
    for (var i = 0; i < 10; ++i) {
        yield return "test\n";
        await Task.Delay(1000);
    }
}

在客户端我尝试了以下方法（遵循这些想法）：

public async IAsyncEnumerable<string?> GetLines() {
    var response = await HttpClient.GetAsync($"{apiRoot}/lines", HttpCompletionOption.ResponseHeadersRead);
    if (response.IsSuccessStatusCode) {
        var responseStream = await response.Content.ReadAsStreamAsync();
        var lines = JsonSerializer.DeserializeAsyncEnumerable<string>(responseStream);
        await foreach (var line in lines) {
            yield return line;
        }
    }
    else {
        Log.Error($"Server response code: {response.StatusCode}");
        yield return null;
    }
}

不幸的是，

response.Content.ReadAsStreamAsync()

不是立即返回，而是缓冲整个流（即 10 行“test ")，在本例中需要 10 秒，然后缓冲内容才会被反序列化为

IAsyncEnumerable<string>

。

使用

HttpClient.GetStreamAsync

可以观察到相同的行为：

public async IAsyncEnumerable<string?> GetLines() {
    var responseStream = await HttpClient.GetStreamAsync($"{apiRoot}/lines"); // buffers for 10 s
    var linesAsync = JsonSerializer.DeserializeAsyncEnumerable<string>(responseStream);
    await foreach (var line in lines) {
        yield return line;
    }
}

如何更改此设置，以便从服务器发送的每一行都立即在客户端上处理，而不需要任何缓冲？ 这是客户端的问题还是服务器端的问题？有没有办法禁用这种缓冲行为？

编辑： 经过更多的实验，我发现直接调用 API（例如通过浏览器）确实显示了预期的流行为，即各行以 1.0 秒的延迟逐行弹出。所以这似乎确实是一个客户端问题。

Answer 1

我找到了一个适合我的解决方法，因为我不需要任何 JSON 反序列化，因为我想流式传输原始字符串。

以下实现解决了客户端流媒体问题：

public async IAsyncEnumerable<string?> GetLines() {
    using var request = new HttpRequestMessage(HttpMethod.Get, $"{apiRoot}/lines");
    request.SetBrowserResponseStreamingEnabled(true);
    var response = await HttpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead);

    if (response.IsSuccessStatusCode) {
        using var responseStream = await response.Content.ReadAsStreamAsync();
        using var reader = new StreamReader(responseStream);
        string? line = null;
        while ((line = await reader.ReadLineAsync()) != null) {
            yield return line;
        }
    }
    else {
        Log.Error($"Server response code: {response.StatusCode}");
        yield return null;
    }
}