AdaSdk.Lifecycle (ada_sdk v0.0.1)

Copy Markdown View Source

Summary

Types

event()
unsubscribe()

Functions

emit(client, event, payload)
on_closed(client, handler)
on_closing(client, handler)
on_connected(client, handler)
on_connecting(client, handler)
on_cursor(client, handler)
on_disconnected(client, handler)
on_listener_error(client, handler)
on_protocol_error(client, handler)
on_reconnecting(client, handler)
on_terminal(client, handler)

Types

event()

@type event() ::
  :stream_connecting
  | :stream_connected
  | :stream_disconnected
  | :stream_cursor
  | :stream_protocol_error
  | :listener_error
  | :stream_reconnecting
  | :stream_terminal
  | :client_closing
  | :client_closed

unsubscribe()

@type unsubscribe() :: (-> :ok)

Functions

emit(client, event, payload)

@spec emit(pid(), event(), term()) :: :ok

on_closed(client, handler)

@spec on_closed(pid(), (-> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_closing(client, handler)

@spec on_closing(pid(), (-> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_connected(client, handler)

@spec on_connected(pid(), (AdaSdk.ConnectedInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_connecting(client, handler)

@spec on_connecting(pid(), (AdaSdk.ConnectingInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_cursor(client, handler)

@spec on_cursor(pid(), (AdaSdk.CursorInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_disconnected(client, handler)

@spec on_disconnected(pid(), (AdaSdk.DisconnectedInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_listener_error(client, handler)

@spec on_listener_error(pid(), (AdaSdk.ListenerErrorInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_protocol_error(client, handler)

@spec on_protocol_error(pid(), (AdaSdk.ProtocolErrorInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_reconnecting(client, handler)

@spec on_reconnecting(pid(), (AdaSdk.ReconnectInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}

on_terminal(client, handler)

@spec on_terminal(pid(), (AdaSdk.TerminalInfo.t() -> term())) ::
  {:ok, unsubscribe()} | {:error, :invalid_handler | :closed}