elixir-mqtt-part1-2.ex

defmodule RaymanPlayground.Application do
  @moduledoc false

  use Application

  def start(_type, _args) do
    {:ok, pid} = :gen_tcp.listen(1883, [
      :binary,
      active: false,
      reuseaddr: true
    ])

    server = spawn(fn ->
      await_connection(pid)
    end)

    {:ok, server}
  end

  defp await_connection(pid) do
    {:ok, client} = :gen_tcp.accept(pid)
    read_data(client)
    await_connection(pid)
  end

  defp read_data(client) do
    {:ok, data} = :gen_tcp.recv(client, 0)
    Rayman.decode_packet(data)
    read_data(client)
  end
end