View Source EventStore.PubSub (EventStore v1.4.6)

Pub/sub using Elixir's local Registry module.

Summary

Functions

broadcast(event_store, topic, message)

Broadcasts message on given topic.

child_spec(event_store)

Return the child spec.

subscribe(event_store, topic, opts \\ [])

Subscribes the caller to the given topic.

Functions

Link to this function

broadcast(event_store, topic, message)

View Source 
@spec broadcast(EventStore.t(), binary(), term()) :: :ok

Broadcasts message on given topic.

Link to this function

child_spec(event_store)

View Source 
@spec child_spec(EventStore.t()) :: [:supervisor.child_spec()]

Return the child spec.

Link to this function

subscribe(event_store, topic, opts \\ [])

View Source 
@spec subscribe(
  EventStore.t(),
  binary(),
  selector: (EventStore.RecordedEvent.t() -> any()),
  mapper: (EventStore.RecordedEvent.t() -> any())
) :: :ok | {:error, term()}

Subscribes the caller to the given topic.