View Source Ash.Reactor.Notifications (ash v3.3.0)

Reactor middleware used to collect and emit notifications upon successful completion of the Reactor.

Summary

When the reactor completes successfully, publish any queued notifications.

Add notifications to the queue to be published on reactor success.

When the reactor fails, discard any queued notifications.

halt(context)

When halting the reactor, store any queued notifications in the context for eventual resumption.

init(context)

When starting a reactor, start an agent to act as a temporary store of notifications.

Dispatch notifications.

When the reactor completes successfully, publish any queued notifications.

@spec enqueue_notifications(
  Reactor.context(),
  Enumerable.t(Ash.Notifier.Notification.t())
) ::
  :ok | {:error, any()}

Add notifications to the queue to be published on reactor success.

When the reactor fails, discard any queued notifications.

When halting the reactor, store any queued notifications in the context for eventual resumption.

When starting a reactor, start an agent to act as a temporary store of notifications.

@spec publish(
  Reactor.context(),
  Ash.Notifier.Notification.t() | [Ash.Notifier.Notification.t()]
) :: [Ash.Notifier.Notification.t()]

Dispatch notifications.