stream-utils / duplex-child-process Goto Github PK

buffer.js:296
    throw new TypeError('"list" argument must be an Array of Buffers');
    ^

TypeError: "list" argument must be an Array of Buffers
    at Function.Buffer.concat (buffer.js:296:11)
    at ChildProcess.onExit (/var/app/current/node_modules/duplex-child-process/index.js:123:50)
    at ChildProcess.g (events.js:291:16)
    at emitTwo (events.js:106:13)
    at ChildProcess.emit (events.js:191:7)
    at maybeClose (internal/child_process.js:877:16)
    at Socket.<anonymous> (internal/child_process.js:334:11)
    at emitOne (events.js:96:13)
    at Socket.emit (events.js:188:7)
    at Pipe._handle.close [as _onclose] (net.js:498:12)

stderr:
null
code:
-2
signal:
null

/home/.../node_modules/duplex-child-process/index.js:146
    cb && cb()
          ^

TypeError: cb is not a function
    at Child_Process.kill (/home/.../node_modules/duplex-child-process/index.js:146:11)
    at internal/streams/pipeline.js:47:61
    at internal/streams/pipeline.js:83:11
    at internal/util.js:392:14
    at Child_Process.<anonymous> (internal/streams/pipeline.js:33:21)
    at Child_Process.<anonymous> (internal/util.js:392:14)
    at Child_Process.onerror (internal/streams/end-of-stream.js:54:14)
    at Child_Process.emit (events.js:321:20)
    at ChildProcess.onExit (/home/.../node_modules/duplex-child-process/index.js:119:12)
    at Object.onceWrapper (events.js:428:26)
    at ChildProcess.emit (events.js:321:20)
    at maybeClose (internal/child_process.js:1026:16)
    at Process.ChildProcess._handle.onexit (internal/child_process.js:286:5)

this.kill = this.destroy = kill

  function kill(cb) {
    that._stdout.destroy()
    that._stderr.destroy()

    killed = true

    try {
      that._process.kill((options && options.killSignal) || 'SIGTERM')
    } catch (e) {
      ex = e
      onExit()
    }
    console.log('cb', cb, new Error().stack)
    cb && cb()
  }

const childProcess = require('duplex-child-process');
const { Readable, Transform } = require('stream');

const reader = new Readable({
    encoding: 'utf-8',
});

const transformer = new Transform({
    transform: (chunk, encoding, callback) => {
        console.log('chunk:', chunk.toString());
        callback(null, chunk);
    }
});

reader
  .pipe(childProcess.spawn('./hellowolrd.py'))
  .pipe(transformer)

reader.push('This is a test.\n');
reader.push('This is a test.\n');
reader.push('This is a test.\n');
reader.push(null);

#!/usr/bin/env python3
import sys

def main():
    for line in sys.stdin:
        sys.stdout.write(line)

if __name__ == '__main__':
    main()

chunk: This is a test.
chunk: This is a test.
chunk: This is a test.

chunk: This is a test.
This is a test.
This is a test.