async-iterator-to-pull-stream - npm Package Compare versions

Comparing version 1.0.1 to 1.1.0

index.js

 module.exports = iterator => {
+  if (!iterator.next) {
+    if (iterator[Symbol.asyncIterator]) {
+      iterator = iterator[Symbol.asyncIterator]()
+    } else if (iterator[Symbol.iterator]) {
+      iterator = iterator[Symbol.iterator]()
+    }
+  }
+
   return async (end, cb) => {
@@ -3,0 +11,0 @@ if (end) return cb(end)

package.json

 {
   "name": "async-iterator-to-pull-stream",
-  "version": "1.0.1",
+  "version": "1.1.0",
   "description": "Convert a (async) iterator to a pull stream",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

@@ -66,1 +66,33 @@ const test = require('ava')
 })
+
+test.cb('should accept iterable', t => {
+  const sourceValues = [1, 2, 3, 4, 5]
+
+  pull(
+    toPull(sourceValues),
+    pull.collect((err, values) => {
+      t.falsy(err)
+      t.deepEqual(values, sourceValues)
+      t.end()
+    })
+  )
+})
+
+test.cb('should accept async iterable', t => {
+  const sourceValues = [1, 2, 3, 4, 5]
+
+  const iterator = async function * () {
+    for (let i = 0; i < sourceValues.length; i++) {
+      yield await futureValue(sourceValues[i], sourceValues[i])
+    }
+  }
+
+  pull(
+    toPull({ [Symbol.asyncIterator]: () => iterator() }),
+    pull.collect((err, values) => {
+      t.falsy(err)
+      t.deepEqual(values, sourceValues)
+      t.end()
+    })
+  )
+})

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

5542

increased by19.39%

Lines of code

102

increased by50%

No dependency changes