Packages

slipstream

1.0.3
1.2.2 1.2.1 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.8.0-rc.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A slick websocket client for Phoenix channels

HexDocs

Current section

Files

Jump to
Readme
48 Versions
4 Dependencies
Dependants
Files
Activity
slipstream lib slipstream message.ex
Raw

lib/slipstream/message.ex 

defmodule Slipstream.Message do

  @moduledoc false



  @type t :: %__MODULE__{

          topic: String.t(),

          event: String.t(),

          payload: term(),

          ref: String.t() | nil,

          join_ref: String.t() | nil

        }



  defstruct ~w[topic event payload ref join_ref]a



  # a wrapper around Phoenix.Socket.Message

  # represents a message sent from the remote websocket server



  @spec from_map!(%{String.t() => term()}) :: t()

  def from_map!(map) when is_map(map) do

    %__MODULE__{

      topic: Map.fetch!(map, "topic"),

      event: Map.fetch!(map, "event"),

      payload: Map.fetch!(map, "payload"),

      ref: Map.fetch!(map, "ref"),

      join_ref: Map.get(map, "join_ref")

    }

  end

end