| 1 | // decode-stream.js
|
| 2 |
|
| 3 | exports.createDecodeStream = DecodeStream;
|
| 4 |
|
| 5 | var util = require("util");
|
| 6 | var Transform = require("stream").Transform;
|
| 7 | var Decoder = require("./decoder").Decoder;
|
| 8 |
|
| 9 | util.inherits(DecodeStream, Transform);
|
| 10 |
|
| 11 | function DecodeStream() {
|
| 12 | if (!(this instanceof DecodeStream)) return new DecodeStream();
|
| 13 | Transform.call(this, {objectMode: true});
|
| 14 | var decoder = new Decoder(this);
|
| 15 | this._transform = decoder.decode.bind(decoder);
|
| 16 | }
|