ASM.Extensions.PubSub.Adapters.Local (ASM v0.9.2)

Copy Markdown View Source

Local in-node PubSub adapter built on Registry duplicate keys.

Broadcast message contract:

  • each subscriber receives {:asm_pubsub, topic, payload}

Summary

Types

registry_ref()
state()

Functions

start_link(opts \\ [])

Types

registry_ref()

@type registry_ref() :: atom() | pid()

state()

@type state() :: %{registry: registry_ref()}

Functions

start_link(opts \\ [])

@spec start_link(keyword()) :: GenServer.on_start() | {:error, ASM.Error.t()}