p-transform
Advanced tools
Comparing version 3.0.0 to 3.0.1
import { type TransformMethod } from './queue.js'; | ||
export { pipeline } from 'node:stream/promises'; | ||
declare const pipeline: any; | ||
export { pipeline }; | ||
export declare const transform: <ChunkType = any>(transform: TransformMethod<ChunkType>) => any; | ||
@@ -4,0 +5,0 @@ /** |
@@ -0,3 +1,5 @@ | ||
import readableStream from 'readable-stream'; | ||
import { OutOfOrder } from './queue.js'; | ||
export { pipeline } from 'node:stream/promises'; | ||
const { pipeline } = readableStream.promises; | ||
export { pipeline }; | ||
export const transform = (transform) => { | ||
@@ -4,0 +6,0 @@ return new OutOfOrder().createTransformStream(transform); |
@@ -83,2 +83,3 @@ var __classPrivateFieldSet = (this && this.__classPrivateFieldSet) || function (receiver, state, value, kind, f) { | ||
}; | ||
// eslint-disable-next-line @typescript-eslint/no-unsafe-call | ||
const writable = new Transform({ | ||
@@ -88,2 +89,3 @@ objectMode: true, | ||
this.add(async () => transform.call(transformContext, chunk)); | ||
// eslint-disable-next-line @typescript-eslint/no-unsafe-call | ||
callback(); | ||
@@ -96,7 +98,4 @@ }, | ||
}); | ||
return Duplex.from({ | ||
// eslint-disable-next-line @typescript-eslint/no-unsafe-call | ||
readable: Readable.from(this), | ||
writable, | ||
}); | ||
// eslint-disable-next-line @typescript-eslint/no-unsafe-call | ||
return Duplex.from({ readable: Readable.from(this), writable }); | ||
} | ||
@@ -103,0 +102,0 @@ /** |
{ | ||
"name": "p-transform", | ||
"version": "3.0.0", | ||
"version": "3.0.1", | ||
"bugs": "https://github.com/mshima/p-transform/issues", | ||
@@ -35,3 +35,2 @@ "repository": { | ||
"devDependencies": { | ||
"@types/readable-stream": "^2.3.15", | ||
"c8": "^7.14.0", | ||
@@ -38,0 +37,0 @@ "esmocha": "^1.0.1", |
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
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
24419
8
177
0