buffer-compression/com.ditchoom.buffer.compression/SuspendingStreamingCompressor

SuspendingStreamingCompressor

interface SuspendingStreamingCompressor : AutoCloseable

Suspending streaming compressor for async-only platforms. Browser JavaScript requires this variant since CompressionStream is async.

Usage:

val compressor = SuspendingStreamingCompressor.create()
try {
    while (hasMoreData) {
        val chunk = receiveChunk()
        compressor.compress(chunk).forEach { send(it) }
    }
    compressor.finish().forEach { send(it) }
} finally {
    compressor.close()
}

Types

object Companion

Properties

abstract val allocator: BufferAllocator

Functions

expect abstract fun close()

abstract suspend fun compress(input: ReadBuffer): List<ReadBuffer>

Compresses input data, returning output chunks. May return empty list if data is buffered.

abstract suspend fun finish(): List<ReadBuffer>

Finishes compression, returning any remaining data.

abstract fun reset()

Resets the compressor for reuse.

inline suspend fun <R> SuspendingStreamingCompressor.use(block: (compress: suspend (ReadBuffer) -> List<ReadBuffer>) -> R): R

Convenience function that handles compress, finish, and close automatically. Returns all output chunks (from both compress and finish calls).