SuspendingStreamingDecompressor

Suspending streaming decompressor for async-only platforms.

Types

abstract val bufferFactory: BufferFactory

expect abstract fun close()

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

Decompresses input data, returning output chunks.

abstract suspend fun finish(): List<ReadBuffer>

Finishes decompression, returning any remaining data.

open suspend fun flush(): List<ReadBuffer>

Emits any buffered partial output without finalizing the stream. See StreamingDecompressor.flush for details.

abstract fun reset()

Resets the decompressor for reuse.

inline suspend fun <R> SuspendingStreamingDecompressor.use(block: (decompress: suspend (ReadBuffer) -> List<ReadBuffer>) -> R): R

Convenience function that handles decompress, finish, and close automatically.