Невозможно создать поток трубопровода с помощью преобразования потоков

Question

Это мой код:

stream = require 'stream' 
stringer = new stream.Transform objectMode: true 
stringer2 = new stream.Transform objectMode: true 

stringer.push 'hello' 
stringer.push 'world' 
stringer.push null 


stringer2._transform = (chunk, enc, done) -> 
    console.log chunk.toString() 
    done() 
    return @ 

stringer.pipe(stringer2).pipe process.stdout 

Я могу войти каждый отдельный кусок в stringer2, но им не удалось трубы в результате к stdout. Как мне это сделать?

Answer 1

Вам необходимо позвонить this.push(chunk), чтобы передать преобразованный кусок на следующий канал. Вы также можете опустить return this, хотя это ничего не повредит.

В CoffeeScript, он будет выглядеть следующим образом:

stringer2._transform = (chunk, enc, done) -> 
    console.log chunk.toString() 
    @push chunk 
    done() 

Или, как ярлык, вы можете передать кусок в done() в качестве второго аргумента (первая ошибка, или нуль, если нет ошибка):

stringer2._transform = (chunk, enc, done) -> 
    console.log chunk.toString() 
    done null, chunk