Plexus.Event (Plexus v0.1.0)

Copy Markdown View Source

Run-local one-shot wake subscriptions used by {:wake_on, event} commands.

Summary

Functions

publish(run_id, event, payload \\ nil)

@spec publish(term(), term(), term()) :: non_neg_integer()

subscribe(run_id, event, actor_id)

@spec subscribe(term(), term(), term()) :: :ok