tree-stream - npm Package Compare versions

Comparing version 1.0.10 to 1.0.11

index.d.ts

@@ -24,4 +24,9 @@ import { Duplex, Readable, Writable } from 'stream'
   const writer: (writeCallback: WritableCallback | WritableCallback[]) => WritableStreamTreeFilter
+
+  const pumpReadable: <X extends unknown>(stream: ReadableStreamTree, resolveValue: X) => Promise<X>
+  const pumpWritable: <X extends unknown>(stream: WritableStreamTree, resolveValue: X, readable?: Readable) => Promise<X>
+  const finishReadable: <X extends unknown>(stream: ReadableStreamTree, resolve: (x: X) => void, reject: (err: Error) => void, resolveValue?: X) => Readable
+  const finishWritable: <X extends unknown>(stream: WritableStreamTree, resolve: (x: X) => void, reject: (err: Error) => void, resolveValue?: X, readable?: Readable) => Writable
 }
 
 export = StreamTree

index.js

@@ -250,2 +250,28 @@ var once = require('once')
 
+var pumpReadable = function(stream, resolveValue) {
+  return new Promise((resolve, reject) => {
+    finishReadable(stream, resolve, reject, resolveValue)
+  })
+}
+
+var pumpWritable = function(stream, resolveValue, readable) {
+  return new Promise((resolve, reject) => {
+    finishWritable(stream, resolve, reject, resolveValue, readable)
+  })
+}
+
+var finishReadable = function(stream, resolve, reject, resolveValue) {
+  return stream.finish((err) => {
+    if (err) reject(err)
+    else resolve(resolveValue)
+  })
+}
+
+var finishWritable = function(stream, resolve, reject, resolveValue, readable) {
+  return stream.finish((err) => {
+    if (err) reject(err)
+    else resolve(resolveValue)
+  }, readable)
+}
+
 module.exports = {
@@ -255,2 +281,6 @@ readable: readableStreamTree,
   writer: streamTreeWriter,
+  pumpReadable: pumpReadable,
+  pumpWritable: pumpWritable,
+  finishReadable: finishReadable,
+  finishWritable: finishWritable,
 }

package.json

 {
   "name": "tree-stream",
-  "version": "1.0.10",
+  "version": "1.0.11",
   "repository": "git://github.com/wholenews/tree-stream",
@@ -5,0 +5,0 @@ "license": "MIT",

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

17678

increased by8.53%

Lines of code

372

increased by8.77%

No dependency changes