如何在Express.js流中使用生成器实现客户端控制数据推送

你当前的实现完全不支持由客户端控制下一个bar对象的流式传输时机，当前逻辑下所有数据的推送节奏100%由服务端决定。

注意：哪怕客户端写了异步生成器逐块读取这个分块响应，也只能控制客户端本地的解析读取节奏，没法反向通知服务端暂停推送、等客户端准备好再发下一块，本质还是服务端单向硬推数据。

现有代码的核心问题 #

• 接口收到请求后会立刻进入for循环，按服务端预设的节奏跑完10次数据推送，哪怕加了freeze(50)做阻塞延迟，这个间隔也是服务端写死的，不会等待客户端的拉取信号。
• 循环执行完成后会直接调用res.end()关闭响应连接，没有预留任何客户端和服务端交互、控制推送节奏的通道。
• 你初始化的可读流写了空的read()方法，根本没有对接流的背压机制感知客户端的消费状态，只是单向往响应里塞数据。

实现客户端控制拉取的改造方向 #

如果要达成「客户端触发一次、服务端才返回下一个bar对象」的效果，不能用当前这种单向HTTP分块响应的写法，可以选两种成熟方案：

• 普通HTTP轮询：客户端每次需要下一个对象时，携带当前已获取的序号发起请求，服务端直接返回对应序号的bar对象即可，实现成本最低。
• WebSocket双向长连接：连接建立后，客户端每发送一次拉取下一条的指令，服务端就推送一个对应序号的bar对象，10条全部推完后可以主动关闭连接，适合需要频繁交互的场景。

内容的提问来源于stack exchange，提问作者jorgeb