@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)