Как правильно сделать Transform Stream?

Question

[Dron Krzh]

Здарова!

Есть задача, запилить клас для загрузки файла (nodejs) должен иметь возможность писать и читать файл.

Теория:

var utils = require('utils');
var TransformStream = require('stream').TransformStream;

function WriteReadStream(path, options) {
  TransformStream.call(this);
}

WriteReadStream.prototype._transform = function(chunk, encoding, cb) {
  // что то нужно сделать здесь
};

utils.inherit(WriteReadStream, TransformStream);

Пишем файл:

var file = new WriteReadStream('/tmp/file');
req.pipe(file);

А потом можем и прочитать:

var file = new WriteReadStream('/tmp/file');
file.pipe(res);

Вообще такое возможно? Или для этого нужно 2 дескриптора для записи (fs.createWriteStream) и чтения (fs.createReadStream)?

Answer 1

[Тимур Шемсединов]

Не оттуда наследуете, смотрите пример в исходниках ноды в /lib/crypto.js
Например класс Hash так написан, он наследует LazyTransform, вот так: util.inherits(Hash, LazyTransform); потом LazyTransform наследует от stream.Transform вот так: util.inherits(LazyTransform, stream.Transform); и потом определен метод _transform

Hash.prototype._transform = function(chunk, encoding, callback) {
  this._binding.update(chunk, encoding);
  callback();
};

Comments

[Dron Krzh]

В чем суть этой прослойки? (LazyTransform)

[Тимур Шемсединов]

Держите готовый:

// Stream

var Transform = require('_stream_transform');
var util = require('util');
util.inherits(NoiseStream, Transform);

function NoiseStream(options) {
  if (!(this instanceof NoiseStream))
    return new NoiseStream(options);
  Transform.call(this, options);
}

NoiseStream.prototype._transform = function(chunk, encoding, cb) {
  var noise = new Buffer('"~-,._.,-~"~-,._.,-~"~-,._');
  cb(null, Buffer.concat([chunk, noise]));
};

// Usage

var fs = require('fs');

var readable = fs.createReadStream('src.dat');
var noise = new NoiseStream();
var writable = fs.createWriteStream('dst.dat');
readable.pipe(noise).pipe(writable);