SukkaSurge/Build/lib/async-write-to-stream.ts

import type { Writable } from 'node:stream';
import { once } from 'node:events';

export function asyncWriteToStream<T>(stream: Writable, chunk: T) {
  const res = stream.write(chunk);
  if (!res) {
    return once(stream, 'drain'); // returns a promise only if needed
  }
}