View Source EventStore.PubSub (EventStore v1.4.0)
Pub/sub using Elixir's local Registry module.
Link to this section Summary
Functions
Broadcasts message on given topic.
Return the child spec.
Subscribes the caller to the given topic.
Link to this section Functions
@spec broadcast(EventStore.t(), binary(), term()) :: :ok
Broadcasts message on given topic.
@spec child_spec(EventStore.t()) :: [:supervisor.child_spec()]
Return the child spec.
@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.