p-transform
Advanced tools
Comparing version 4.1.4 to 4.1.5
@@ -0,1 +1,2 @@ | ||
import { setTimeout } from 'node:timers/promises'; | ||
import { Readable as _Readable, Duplex as _Duplex } from 'readable-stream'; | ||
@@ -85,2 +86,7 @@ import PQueue from 'p-queue'; | ||
this.push(chunk); | ||
// Wait next tick to continue. | ||
// Improves responsiveness since it prioritize chunks to pass through the entire pipeline instead of buffering in a transform. | ||
if (this.#queue.pending > 1) { | ||
await setTimeout(); | ||
} | ||
} | ||
@@ -87,0 +93,0 @@ await this.flush(); |
{ | ||
"name": "p-transform", | ||
"version": "4.1.4", | ||
"version": "4.1.5", | ||
"bugs": "https://github.com/mshima/p-transform/issues", | ||
@@ -5,0 +5,0 @@ "repository": { |
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
24014
204