Fledex.Utils.PubSub (fledex v0.6.0)

Summary

Functions

broadcast(pubsub \\ Utils.pubsub_name(), topic, message)

See Phoenix.PubSub.broadcast/3.

broadcast_state(state, context)

broadcast_trigger(message)

channel_state()

channel_trigger()

direct_broadcast!(node, pubsub \\ Utils.pubsub_name(), topic, message)

See Phoenix.PubSub.direct_broadcast!/4.

subscribe(pubsub \\ Utils.pubsub_name(), topic)

See Phoenix.PubSub.subscribe/2.

unsubscribe(pubsub \\ Utils.pubsub_name(), topic)

See Phoenix.PubSub.unsubscribe/2.

Functions

broadcast(pubsub \\ Utils.pubsub_name(), topic, message)

See Phoenix.PubSub.broadcast/3.

broadcast_state(state, context)

@spec broadcast_state(any(), map()) :: :ok | {:error, term()}

broadcast_trigger(message)

@spec broadcast_trigger(map()) :: :ok | {:error, term()}

channel_state()

@spec channel_state() :: String.t()

channel_trigger()

@spec channel_trigger() :: String.t()

direct_broadcast!(node, pubsub \\ Utils.pubsub_name(), topic, message)

See Phoenix.PubSub.direct_broadcast!/4.

unsubscribe(pubsub \\ Utils.pubsub_name(), topic)

See Phoenix.PubSub.unsubscribe/2.