stream-to-pull-stream
Advanced tools
Comparing version 1.6.8 to 1.6.9
17
index.js
@@ -18,2 +18,13 @@ var pull = require('pull-stream/pull') | ||
function destroy (stream) { | ||
if(!stream.destroy) | ||
console.error( | ||
'warning, stream-to-pull-stream: \n' | ||
+ 'the wrapped node-stream does not implement `destroy`, \n' | ||
+ 'this may cause resource leaks.' | ||
) | ||
else stream.destroy() | ||
} | ||
function write(read, stream, cb) { | ||
@@ -54,3 +65,3 @@ var ended, closed = false, did | ||
if(ended = ended || end) { | ||
stream.destroy && stream.destroy() | ||
destroy(stream) | ||
return done(ended) | ||
@@ -158,3 +169,3 @@ } | ||
}) | ||
stream.destroy() | ||
destroy(stream) | ||
} | ||
@@ -206,1 +217,3 @@ cbs.push(cb) | ||
{ | ||
"name": "stream-to-pull-stream", | ||
"description": "convert a stream1 or streams2 stream into a pull-stream", | ||
"version": "1.6.8", | ||
"version": "1.6.9", | ||
"homepage": "https://github.com/dominictarr/stream-to-pull-stream", | ||
@@ -14,2 +14,3 @@ "repository": { | ||
"devDependencies": { | ||
"pull-split": "^0.2.0", | ||
"tape": "^4.5.1", | ||
@@ -16,0 +17,0 @@ "through": "~2.3.4" |
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
13392
447
3