import { drain } from '@kanziw/stream'

const buf = await drain(someStream)

import { waitUntilFinished } from '@kanziw/stream'

await waitUntilFinished(someStream)