pipe-into.ts
No OneTemporary
Actions

Size

465 B

Referenced Files

None

Subscribers

None

pipe-into.ts
View Options

	import { Writable, Readable } from "stream";
	import { TempStream } from ".";

	export default function pipeInto(
	fromStream: Readable \| TempStream,
	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());
	fromStream.on("error", (error) => {
	reject(error);
	});
	});
	}