Parrhesia.Fanout.Dispatcher (parrhesia v0.14.0)

Copy Markdown

Asynchronous local fanout dispatcher.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

dispatch(event)
dispatch(server, event)
dispatch_many(events)
dispatch_many(server, events)
start_link(opts \\ [])

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

dispatch(event)

@spec dispatch(map()) :: :ok

dispatch(server, event)

@spec dispatch(GenServer.server(), map()) :: :ok

dispatch_many(events)

@spec dispatch_many([map()]) :: :ok

dispatch_many(server, events)

@spec dispatch_many(GenServer.server(), [map()]) :: :ok

start_link(opts \\ [])

@spec start_link(keyword()) :: GenServer.on_start()