Packages

conduit

0.7.0
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit encoding gzip.ex
Raw

lib/conduit/encoding/gzip.ex 

defmodule Conduit.Encoding.GZip do

  use Conduit.Encoding

  @moduledoc """

  Handles encoding a message body to and from gzip.

  """



  @doc """

  Encodes the message body to gzip and sets the content encoding.



  ## Examples



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body("{}")

      iex>   |> Conduit.Encoding.GZip.encode([])

      iex> message.body

      <<31, 139, 8, 0, 0, 0, 0, 0, 0, 3, 171, 174, 5, 0, 67, 191, 166, 163, 2, 0, 0, 0>>

      iex> message.content_encoding

      "gzip"



  """

  def encode(message, _opts) do

    message

    |> put_body(:zlib.gzip(message.body))

    |> put_content_encoding("gzip")

  end



  @doc """

  Decodes the message body from gzip and sets the content encoding.



  ## Examples



      iex> import Conduit.Message

      iex> message =

      iex>   %Conduit.Message{}

      iex>   |> put_body(<<31, 139, 8, 0, 0, 0, 0, 0, 0, 3, 171, 174, 5, 0, 67, 191, 166, 163, 2, 0, 0, 0>>)

      iex>   |> Conduit.Encoding.GZip.decode([])

      iex> message.body

      "{}"

      iex> message.content_encoding

      "gzip"



  """

  def decode(message, _opts) do

    message

    |> put_body(:zlib.gunzip(message.body))

    |> put_content_encoding("gzip")

  end

end