TanTan
e311ca3275
Build NapCat Artifacts / Windows Loader Test (push) Canceled after 0s
Build NapCat Artifacts / Type Check & Test (push) Canceled after 0s
Build NapCat Artifacts / Build NapCat.Framework (push) Canceled after 0s
Build NapCat Artifacts / Build NapCat.Shell (push) Canceled after 0s
28 lines
685 B
Plaintext
28 lines
685 B
Plaintext
'use strict';
|
|
|
|
var util = require('util');
|
|
var stream = require('stream');
|
|
|
|
module.exports.createReadStream = function (object, options) {
|
|
return new MultiStream (object, options);
|
|
};
|
|
|
|
var MultiStream = function (object, options) {
|
|
if (object instanceof Buffer || typeof object === 'string') {
|
|
options = options || {};
|
|
stream.Readable.call(this, {
|
|
highWaterMark: options.highWaterMark,
|
|
encoding: options.encoding
|
|
});
|
|
} else {
|
|
stream.Readable.call(this, { objectMode: true });
|
|
}
|
|
this._object = object;
|
|
};
|
|
|
|
util.inherits(MultiStream, stream.Readable);
|
|
|
|
MultiStream.prototype._read = function () {
|
|
this.push(this._object);
|
|
this._object = null;
|
|
}; |