compressStream

suspend fun CompressionMethod.compressStream(    input: AsyncInputStream,     context: CompressionContext = CompressionContext(),     bufferSize: Int = AsyncByteArrayDequeChunked.DEFAULT_MAX_SIZE): AsyncInputStream