gossamer/compression_stream

Types

CompressionStream

An API for compressing a stream of data.

Examples

let assert Ok(compressor) = compression_stream.new(compression_format.Gzip)

stdin.readable()
|> readable_stream.pipe_through(
  #(
    compression_stream.readable(compressor),
    compression_stream.writable(compressor),
  ),
  [],
)
|> readable_stream.pipe_to(stdout.writable(), [])

pub type CompressionStream

Values

new

</>

pub fn new(
  format: compression_format.CompressionFormat,
) -> Result(CompressionStream, String)

Returns an error if the format is not supported.

readable

</>

pub fn readable(
  of stream: CompressionStream,
) -> readable_stream.ReadableStream(uint8_array.Uint8Array)

writable

</>

pub fn writable(
  of stream: CompressionStream,
) -> writable_stream.WritableStream(uint8_array.Uint8Array)