Returns a specification to start this module under a supervisor.

See Supervisor.

@spec emit(
  pid(),
  struct()
) :: :ok

Emits an event to all subscribers asynchronously.

Parameters

• pid - The EventEmitter process
• event - The event struct to emit

Examples

EventEmitter.emit(emitter, %GoalSubmittedEvent{state: state})

Starts the EventEmitter GenServer.

@spec subscribe(pid(), module(), function()) :: reference()

Subscribes to an event type.

Returns a reference that can be used to unsubscribe.

Parameters

• pid - The EventEmitter process
• event_type - The event module to subscribe to
• callback - Function to call when event is emitted

Examples

ref = EventEmitter.subscribe(emitter, GoalSubmittedEvent, fn event ->
  IO.inspect(event)
end)

EventEmitter.unsubscribe(emitter, ref)

@spec unsubscribe(pid(), reference()) :: :ok

Unsubscribes from events using the reference returned by subscribe.