目前,我正在使用一个名为“ChunkingStream”的转换流来接收和处理来自 TCP 套接字(并通过管道传输到其他地方)的数据。一般结构与nodejs doc中给出的示例几乎相同:
ChunkingStream.prototype._transform = function (chunk, encoding, callback) {
// extract data from chunk
this.push(data);
callback();
};
然而,由于数据块的顺序在这个问题中很重要,它看起来像这样的调用:
this.push(data);
是异步的。
因此有什么方法可以使上述调用同步吗?干杯!