40 lines
1.0 KiB
TypeScript
40 lines
1.0 KiB
TypeScript
|
// Ensure this test runs in both Node.js & Bun to verify compatibility.
|
||
|
|
import assert from "node:assert";
|
||
|
|
import { Readable, Transform } from "node:stream";
|
||
|
|
import { test } from "node:test";
|
||
|
|
|
||
|
|
test("piping object-mode source into byte-mode destination emits catchable error", async () => {
|
||
|
|
const objectReadable = Readable.from([{ hello: "world" }]);
|
||
|
|
|
||
|
|
const passThrough = new Transform({
|
||
|
|
objectMode: false,
|
||
|
|
transform(chunk, _encoding, cb) {
|
||
|
|
this.push(chunk);
|
||
|
|
cb();
|
||
|
|
},
|
||
|
|
});
|
||
|
|
|
||
|
|
const errors: Error[] = [];
|
||
|
|
|
||
|
|
passThrough.on("error", err => {
|
||
|
|
errors.push(err);
|
||
|
|
});
|
||
|
|
|
||
|
|
objectReadable.pipe(passThrough);
|
||
|
|
|
||
|
|
let caughtError: Error | undefined;
|
||
|
|
try {
|
||
|
|
for await (const _v of passThrough) {
|
||
|
|
// should not receive any data
|
||
|
|
}
|
||
|
|
} catch (e: any) {
|
||
|
|
caughtError = e;
|
||
|
|
}
|
||
|
|
|
||
|
|
assert.ok(caughtError);
|
||
|
|
assert.strictEqual((caughtError as any).code, "ERR_INVALID_ARG_TYPE");
|
||
|
|
|
||
|
|
assert.strictEqual(errors.length, 1);
|
||
|
|
assert.strictEqual((errors[0] as any).code, "ERR_INVALID_ARG_TYPE");
|
||
|
|
});
|