it-to-stream
Advanced tools
Comparing version 0.1.1 to 0.1.2
{ | ||
"name": "it-to-stream", | ||
"version": "0.1.1", | ||
"version": "0.1.2", | ||
"description": "Convert streaming iterables to Node.js streams", | ||
@@ -21,3 +21,3 @@ "main": "src/index.js", | ||
"dependencies": { | ||
"buffer": "^5.2.1", | ||
"buffer": "^5.6.0", | ||
"fast-fifo": "^1.0.0", | ||
@@ -27,14 +27,10 @@ "get-iterator": "^1.0.2", | ||
"p-fifo": "^1.0.0", | ||
"readable-stream": "^3.4.0" | ||
"readable-stream": "^3.6.0" | ||
}, | ||
"devDependencies": { | ||
"ava": "^2.2.0", | ||
"ava": "^3.9.0", | ||
"it-pair": "^1.0.0", | ||
"nyc": "^14.1.1", | ||
"standard": "^13.1.0" | ||
"nyc": "^15.1.0", | ||
"standard": "^14.3.4" | ||
}, | ||
"ava": { | ||
"babel": false, | ||
"compileEnhancements": false | ||
}, | ||
"directories": { | ||
@@ -41,0 +37,0 @@ "test": "test" |
@@ -106,2 +106,7 @@ # it-to-stream | ||
## Related | ||
* [`stream-to-it`](https://www.npmjs.com/package/stream-to-it) Convert Node.js streams to streaming iterables | ||
* [`it-pipe`](https://www.npmjs.com/package/it-pipe) Utility to "pipe" async iterables together | ||
## Contribute | ||
@@ -108,0 +113,0 @@ |
const { Readable, Writable, Duplex } = require('stream') | ||
const getIterator = require('get-iterator') | ||
const Fifo = require('p-fifo') | ||
const { Buffer } = require('buffer') | ||
const END_CHUNK = Buffer.alloc(0) | ||
@@ -5,0 +6,0 @@ |
@@ -7,3 +7,4 @@ const { Writable, pipeline } = require('stream') | ||
pipeline(...streams, err => { | ||
if (err) return reject(err) | ||
// work around bug in node to make 'should end mid stream' test pass - https://github.com/nodejs/node/issues/23890 | ||
if (err && err.code !== 'ERR_STREAM_PREMATURE_CLOSE') return reject(err) | ||
resolve() | ||
@@ -10,0 +11,0 @@ }) |
const test = require('ava') | ||
const { Readable } = require('stream') | ||
const { Buffer } = require('buffer') | ||
const toStream = require('../') | ||
@@ -4,0 +5,0 @@ const { collect } = require('./helpers/streams') |
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
16726
375
118
Updatedbuffer@^5.6.0
Updatedreadable-stream@^3.6.0