Sourced.EventStore.Postgres.Subscription (sourced_postgres v0.1.0)

Copy Markdown View Source

A dynamically started GenServer for listening to appended events and dispatching to the caller.

Summary

Functions

Returns a specification to start this module under a supervisor.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(subscription)

@spec start_link(subscription :: Sourced.EventStore.Subscription.t()) ::
  GenServer.on_start()

unsubscribe(store, subscription)

@spec unsubscribe(
  store :: Sourced.EventStore.t(),
  subscription :: Sourced.EventStore.Subscription.t()
) ::
  :ok