javascript - Node.js 中的 `stream.Transform.unshift()`

Question

考虑一个简单的例子:

stream = require 'stream'
util = require 'util'

class TestTransform extends stream.Transform
    _transform: (chunk, encoding, callback) ->
        if not @noMore
            @noMore = true
            @unshift chunk # I will handle you later
        else
            @push " <#{chunk.toString().toUpperCase()}>"
        callback()

mt = new TestTransform()
mt.write 'first'
mt.write 'second'
mt.on 'data', (chunk) -> console.log "data: #{util.inspect chunk.toString()}"

$ coffee test.coffee
data: 'first <SECOND>'

此转换流尝试将其第一个 block 推回读取队列，因此它将在下一个 _transform 调用中处理。

但出于某种原因，unshifting in Transform 导致数据立即进入输出而无需再次进入 _transform(因此不会大写).这是故意的还是我遗漏了什么？

Answer 1

unshift 是一个Readable 方法。这意味着当您在转换中调用它时，您会将内容推回输出端缓冲区，而不是输入端。

不要这样做。由于您无法知道输出端缓冲区中有多少内容，因此这实际上是以不确定的顺序推送数据。