Packages

tortoise

0.8.3
0.10.0 0.9.9 0.9.8 0.9.6 0.9.5 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.0 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.2 0.2.1 0.2.0 0.1.0

A MQTT client for Elixir.

HexDocs

Current section

Files

Jump to
Readme
27 Versions
2 Dependencies
Dependants
Files
Activity
tortoise lib tortoise decodable.ex
Raw

lib/tortoise/decodable.ex 

defprotocol Tortoise.Decodable do

  @moduledoc false



  def decode(data)

end



defimpl Tortoise.Decodable, for: BitString do

  alias Tortoise.Package.{

    Connect,

    Connack,

    Publish,

    Puback,

    Pubrec,

    Pubrel,

    Pubcomp,

    Subscribe,

    Suback,

    Unsubscribe,

    Unsuback,

    Pingreq,

    Pingresp,

    Disconnect

  }



  def decode(<<1::4, _::4, _::binary>> = data), do: Connect.decode(data)

  def decode(<<2::4, _::4, _::binary>> = data), do: Connack.decode(data)

  def decode(<<3::4, _::4, _::binary>> = data), do: Publish.decode(data)

  def decode(<<4::4, _::4, _::binary>> = data), do: Puback.decode(data)

  def decode(<<5::4, _::4, _::binary>> = data), do: Pubrec.decode(data)

  def decode(<<6::4, _::4, _::binary>> = data), do: Pubrel.decode(data)

  def decode(<<7::4, _::4, _::binary>> = data), do: Pubcomp.decode(data)

  def decode(<<8::4, _::4, _::binary>> = data), do: Subscribe.decode(data)

  def decode(<<9::4, _::4, _::binary>> = data), do: Suback.decode(data)

  def decode(<<10::4, _::4, _::binary>> = data), do: Unsubscribe.decode(data)

  def decode(<<11::4, _::4, _::binary>> = data), do: Unsuback.decode(data)

  def decode(<<12::4, _::4, _::binary>> = data), do: Pingreq.decode(data)

  def decode(<<13::4, _::4, _::binary>> = data), do: Pingresp.decode(data)

  def decode(<<14::4, _::4, _::binary>> = data), do: Disconnect.decode(data)

end



defimpl Tortoise.Decodable, for: List do

  def decode(data) do

    data

    |> IO.iodata_to_binary()

    |> Tortoise.Decodable.decode()

  end

end