0

目前,我正在使用一个名为“ChunkingStream”的转换流来接收和处理来自 TCP 套接字(并通过管道传输到其他地方)的数据。一般结构与nodejs doc中给出的示例几乎相同:

ChunkingStream.prototype._transform = function (chunk, encoding, callback) {
    // extract data from chunk
    this.push(data);
    callback();
};

然而,由于数据块的顺序在这个问题中很重要,它看起来像这样的调用:

this.push(data);

是异步的。

因此有什么方法可以使上述调用同步吗?干杯!

4

0 回答 0