pipe-into.ts
No OneTemporary
Actions

Size

391 B

Referenced Files

None

Subscribers

None

pipe-into.ts
View Options

	import { Writable, Readable } from "stream";

	export default function pipeInto(
	fromStream: Readable,
	push: (data: any) => void
	) {
	let outStream = fromStream.pipe(
	new Writable({
	write(data, _, next) {
	push(data);
	next(null);
	},
	})
	);

	return new Promise<void>((resolve, reject) => {
	outStream.on("finish", () => resolve());
	outStream.on("error", reject);
	});
	}