Socket
Socket
Sign inDemoInstall

streamsink

Package Overview
Dependencies
Maintainers
1
Versions
5
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

streamsink - npm Package Compare versions

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) {

2

package.json
{
"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 @@ });

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc