Singyeong.Consumer behaviour (singyeong v0.4.14) View Source

Link to this section Summary

Link to this section Types

Specs

event() ::
  {:send, String.t() | nil, term()}
  | {:broadcast, String.t() | nil, term()}
  | {:queue, String.t(), String.t() | nil, term()}
  | {:queue_confirm, String.t()}

Link to this section Functions

Link to this function

handle_events(events, from, state)

View Source

Link to this section Callbacks

Specs

handle_event(event()) :: term()