Node.js: Почему никогда не вызывается функция преобразования потока Transform? - PullRequest
Новая
       25

Node.js: Почему никогда не вызывается функция преобразования потока Transform?

0 голосов
/ 03 февраля 2020

Я пытаюсь записать пользовательский поток преобразователя в Node.js 12. В частности, я беру json объекты в потоке (драйвер базы данных) и возвращаю преобразованный объект. Но мои функции-трансформеры никогда не вызываются. Я также попробовал это, переопределив класс streams.Transform.

Я хочу сделать пользовательское преобразование generi c, поэтому я заключаю его в замыкание, чтобы передать функцию generi c : 

// transformStream.js
var through2, transformStream;

through2 = require('through2');

transformStream = (handler) => {
  // Through2 in Object Mode
  _transformStream = through2.obj((data, encoding, callback) => {
    console.log(data); // Never called
    this.push(handler(data));
    return callback();
    // also tried:
    // return callback(null, handler(data));
  });

  return _transformStream;
};

module.exports = transformStream;

Вот тестовый стенд для его тестирования: 

// transformStream.test.js
var jsonStream, through2, transformFunc, transformStream, transformer;

through2 = require('through2');
transformStream = require('./transformStream.js');

// Convert back to a string buffer for console output.
jsonStream = through2.obj(function(chunk, encoding, callback) {
  return callback(null, JSON.stringify(chunk, null, 2) + '\n');
});

transformFunc = function(data) {
  console.log("called with data", data); // Never called!
  data.c = data.a * data.b;
  return data;
};

// deviceStream.pipe(process.stdout)
transformer = transformStream(transformFunc);

transformer.on("error", function(error) {
  return console.error(`Error in Transform: ${error.message}`);
});

transformer.pipe(jsonStream).pipe(process.stdout);

transformer.push({
  a: 1,
  b: 2
});

Поток, кажется, работает, никогда не вызывает фактический код преобразования и всегда возвращает только исходный json: 

{
  A: 1,
  b: 2
}

в консоли.

Я ожидаю увидеть: { a: 1, b:2, c:2 }

EDIT : у меня также есть другая версия с использованием классов (в обход сквозь 2) с точно такой же проблемой: 

module.exports = TransformStream = class TransformStream extends Transform {
  constructor(handler, {debug, highWaterMark, ...options}) {
    super({
      highWaterMark: highWaterMark || 10,
      autoDestroy: true,
      emitClose: true,
      objectMode: true,
      debug: true
    });
    this._transform = this._transform.bind(this);
    this.handler = handler;
    this.debug = debug;
    this.options = options;
  }
};

TransformStream.prototype._transform = (data, encoding, callback) => {
  if (this.debug) {
    console.log(data);
  }
  return callback(null, this.handler(data));
};

1 Ответ

0 голосов
/ 03 февраля 2020

Видимо, выполнение TransformClass.push вызывает внутренний буфер вывода для потока. На самом деле поток ожидает метод .write({}) и, соответственно, вызывает функции _transform.

В тестовой установке последний тест должен быть: 

transformer.write({
  a: 1,
  b: 2
});
...