@kanziw/stream drain Drain stream import { drain } from '@kanziw/stream' const buf = await drain(someStream) waitUntilFinished Wait until stream finished import { waitUntilFinished } from '@kanziw/stream' await waitUntilFinished(someStream)