Comparing version 1.1.1 to 1.2.0
16
index.js
@@ -5,3 +5,19 @@ var stream = require('stream'); | ||
module.exports = StreamSink; | ||
StreamSink.fromBuffer = fromBuffer; | ||
StreamSink.fromBufferList = fromBufferList; | ||
function fromBuffer(buffer, options) { | ||
return fromBufferList([buffer], options); | ||
} | ||
function fromBufferList(bufferList, options) { | ||
var sink = new StreamSink(options); | ||
sink.buffer = bufferList; | ||
sink.length = 0; | ||
bufferList.forEach(function(buffer) { | ||
sink.length += buffer.length; | ||
}); | ||
return sink; | ||
} | ||
util.inherits(StreamSink, stream.Writable); | ||
@@ -8,0 +24,0 @@ function StreamSink(options) { |
{ | ||
"name": "streamsink", | ||
"version": "1.1.1", | ||
"version": "1.2.0", | ||
"description": "pipe to a buffer, then create readable streams from it", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -24,2 +24,5 @@ # node-streamsink | ||
}); | ||
// you can also create instances from a list of buffers | ||
var sink = StreamSink.fromBufferList([new Buffer("aoeu"), new Buffer("foo")]); | ||
``` |
@@ -14,2 +14,9 @@ var StreamSink = require('./'); | ||
assert.strictEqual(buf[1], 105); | ||
var s2 = StreamSink.fromBuffer(new Buffer("aoeu")); | ||
assert.strictEqual(s2.toString(), "aoeu"); | ||
var s3 = StreamSink.fromBufferList([new Buffer("aoeu"), new Buffer("asdf")]); | ||
assert.strictEqual(s3.toString(), "aoeuasdf"); | ||
console.log("OK"); | ||
@@ -16,0 +23,0 @@ }); |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
4308
67
28