Packages

zstream

0.6.5
0.6.7 0.6.6 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.2 0.5.1 0.5.0 0.4.0 0.3.1 0.3.0 0.2.0 0.1.1 0.1.0

Streaming zip file writer and reader

HexDocs

Current section

Files

Jump to
Readme
17 Versions
0 Dependencies
Dependants
Files
Activity
zstream lib zstream decoder deflate.ex
Raw

lib/zstream/decoder/deflate.ex 

defmodule Zstream.Decoder.Deflate do

  @moduledoc false

  @behaviour Zstream.Decoder



  def init() do

    z = :zlib.open()

    :ok = :zlib.inflateInit(z, -15)

    z

  end



  def decode(chunk, z) do

    acc = :zlib.safeInflate(z, IO.iodata_to_binary(chunk))



    chunks =

      Stream.unfold(acc, fn

        {:continue, data} ->

          {{:data, data}, :zlib.safeInflate(z, [])}



        {:finished, data} ->

          {{:data, data}, nil}



        nil ->

          nil

      end)



    {chunks, z}

  end



  def close(z) do

    :ok = :zlib.inflateEnd(z)

    :ok = :zlib.close(z)

    []

  end

end