Compressors (tapak-compressions.Tapak_compressions.Compressors)

type stream_state = {

zstream : Zlib.stream;
mutable finished : bool;
mutable cleaned_up : bool;
buf_size : int;

}

val create_stream_state : 
  ?buf_size:int ->
  use_zlib_wrapper:bool ->
  unit ->
  stream_state

val cleanup_stream : stream_state -> unit

val decompress_chunk : 
  stream_state ->
  string ->
  off:int ->
  len:int ->
  string option * int

val parse_gzip_header : 
  string ->
  (int,
    [> `Invalid_gzip_header
    | `Need_more_data
    | `Unsupported_compression_method ])
    Stdlib.result

val decompress_deflate_stream : 
  Bigstringaf.t Piaf.IOVec.t Piaf.Stream.t ->
  string Piaf.Stream.t

val decompress_gzip_stream : 
  Bigstringaf.t Piaf.IOVec.t Piaf.Stream.t ->
  string Piaf.Stream.t

val create_gzip_header : unit -> string

val compress_stream : 
  use_gzip_wrapper:bool ->
  string Piaf.Stream.t ->
  string Piaf.Stream.t

module Deflate : sig ... end

module Gzip : sig ... end

module Brotli : sig ... end

module Zstd : sig ... end