buffered

fun AsyncStream.buffered(blockSize: Int = 2048, blocksToRead: Int = 16): AsyncStream