dart - 使用 Redstone/Shelf 在 Dart 中流式传输文本

Question

我突然想到流式传输字符串是有意义的，每个字符串代表来自数据库查询的一个元素，而不是在过程结束时返回它们的整个列表，这可能会在浏览器上更早地获得第一个结果.所以我尝试用 Redstone 来实现它使用Shelf .这是我的基本测试

@app.Route ('/testStream')
testSream ()
{
    StreamController<String> controller = new StreamController<String> ();

    () async
    {
        var initialTime = new DateTime.now();

        await new Future.delayed (new Duration (seconds: 1));
        controller.add("hello\n");

        await new Future.delayed (new Duration (seconds: 10));
        controller.add("chao\n");

        var finalTime = new DateTime.now().difference(initialTime);

        controller.add(finalTime.toString());

        controller.close();

    }();

    Stream<List<int>> intStream = controller.stream.map((s) => s.codeUnits);

    return new shelf.Response.ok (intStream);
}

只是在某些情况下，Linked-in 的人使用他们从 Facebook 获得的模式中的“文本流”来快速呈现页面的一部分并插入一些后者(如果可用)，他们在 Playframework (Scala) 中实现了这一点他们在哪里使用 Enumerables这看起来就像 Dart 流一样。你可以在 this video 中看到它.

我的代码的问题在于，虽然我希望它显示 "hello" 1 秒 后，"chao" 10 秒 后。我得到的是 11 秒 的等待，然后是完整的文本。如您所见，我正在回复 Shelf.Response用Stream<List<int>>每个List<int>只是将原始流中的字符串转换为字节。

这是 Shelf 问题/功能，还是 Redstone 搞乱了响应并将其转换为 future ？有什么解决办法吗？

编辑

我想得到什么

1 秒内没有任何内容。

1秒后

hello

11 秒后

hello
chao
0:00:11.009000

我真正得到了什么

1 秒内没有任何内容。

11 秒后

hello
chao
0:00:11.009000

Answer 1

对于那些后来到这里的人:

正如@Pacane 在问题评论中所建议的，他发布的链接 ( https://github.com/dart-lang/shelf/issues/54 ) 确实包含 Andersmholmgren 的评论，该评论适用于该问题:

return new Response.ok(counterStream, context: {"shelf.io.buffer_output": false}); 

将“shelf.io.buffer_output”选项设置为 false 会禁用 Shelf 的输出缓冲区，并使添加到响应流的字节直接通过网络发送到客户端。