tai v0.0.75

Tai.Venues.Streams.ConnectionAdapter behaviour (tai v0.0.75)

Link to this section Summary

Types

msg()
phase()
received_at()
state()

Callbacks

on_connect(t, state)
on_disconnect(connection_status_map, state)
on_msg(msg, received_at, state)
on_terminate(close_reason, state)
subscribe(phase, state)

Link to this section Types

Link to this type

msg()

Specs

msg() :: term()
Link to this type

phase()

Specs

phase() :: :init | atom()
Link to this type

received_at()

Specs

received_at() :: integer()
Link to this type

state()

Specs

state() :: Tai.Venues.Streams.ConnectionAdapter.State.t()

Link to this section Callbacks

Link to this callback

on_connect(t, state)

Specs

on_connect(WebSockex.Conn.t(), state()) :: {:ok, state()}
Link to this callback

on_disconnect(connection_status_map, state)

Specs

on_disconnect(WebSockex.connection_status_map(), state()) :: {:ok, state()}
Link to this callback

on_msg(msg, received_at, state)

Specs

on_msg(msg(), received_at(), state()) :: {:ok, state()}
Link to this callback

on_terminate(close_reason, state)

Specs

on_terminate(WebSockex.close_reason(), state()) :: {:ok, state()}
Link to this callback

subscribe(phase, state)

Specs

subscribe(phase(), state()) :: {:ok, state()}