Packages

slipstream

0.4.0
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
5 Dependencies
Dependants
Files
Activity
slipstream lib slipstream connection.ex
Raw

lib/slipstream/connection.ex 

defmodule Slipstream.Connection do

  @moduledoc false



  # the Connection _is_ the socket client

  # Connection interfaces with :gun and any module that implements the

  # Slipstream behaviour to offer websocket client functionality



  use GenServer, restart: :temporary



  alias Slipstream.Connection.{State, Pipeline, Telemetry}



  def start_link(init_arg) do

    GenServer.start_link(__MODULE__, init_arg)

  end



  @impl GenServer

  def init(%Slipstream.Commands.OpenConnection{

        socket: %Slipstream.Socket{socket_pid: socket_pid},

        config: config

      }) do

    initial_state = State.new(config, socket_pid)



    metadata = Telemetry.begin(initial_state)



    state = %State{initial_state | metadata: metadata}



    {:ok, state, {:continue, :connect}}

  end



  @impl GenServer

  def handle_continue(:connect, state) do

    Pipeline.handle(:connect, state)

  end



  @impl GenServer

  def handle_info(message, state) do

    Pipeline.handle(message, state)

  end



  @impl GenServer

  def handle_call(message, _from, state) do

    Pipeline.handle(message, state)

  end



  @impl GenServer

  def terminate(reason, state) do

    Telemetry.conclude(state, reason)



    state

  end

end