bare-stream
Advanced tools
+1
-1
| { | ||
| "name": "bare-stream", | ||
| "version": "2.8.0", | ||
| "version": "2.8.1", | ||
| "description": "Streaming data for JavaScript", | ||
@@ -5,0 +5,0 @@ "exports": { |
+9
-3
@@ -87,3 +87,5 @@ const { Readable, Writable, getStreamError, isStreamx, isDisturbed } = require('streamx') | ||
| return new Promise((resolve) => stream.once('close', resolve).destroy(reason)) | ||
| return new Promise((resolve) => | ||
| stream.once('close', resolve).once('error', noop).destroy(reason) | ||
| ) | ||
| } | ||
@@ -175,7 +177,11 @@ } | ||
| cancel(reason = new TypeError('Stream was cancelled')) { | ||
| if (this._stream.destroyed) return Promise.resolve() | ||
| const stream = this._stream | ||
| if (stream.destroyed) return Promise.resolve() | ||
| if (this.locked) return Promise.reject(new TypeError('Stream is locked')) | ||
| return new Promise((resolve) => this._stream.once('close', resolve).destroy(reason)) | ||
| return new Promise((resolve) => | ||
| stream.once('close', resolve).once('error', noop).destroy(reason) | ||
| ) | ||
| } | ||
@@ -182,0 +188,0 @@ |
40536
0.21%860
0.58%