Dispenser.SubscriptionManager (dispenser v0.1.1) View Source

SubscriptionManager handles monitoring and demonitoring subscribers

Link to this section Summary

t()

The opaque internal state of the SubscriptionManager.

Stop monitoring the given subscriber.

Handle the down signal from a monitored subscriber.

Monitor the given pid using Process.monitor/1. Callers must handle the :DOWN message from this pid.

new()

Get the number of currently monitored subscribers.

(opaque)

t()

The opaque internal state of the SubscriptionManager.

demonitor(t(), pid()) :: {:ok, t()} | {:error, :not_subscribed}

Stop monitoring the given subscriber.

down(t(), pid(), reference()) ::
  {:ok, t()} | {:error, :wrong_ref} | {:error, :not_subscribed}

Handle the down signal from a monitored subscriber.

monitor(t(), pid()) :: t()

Monitor the given pid using Process.monitor/1. Callers must handle the :DOWN message from this pid.

new() :: t()

size(t()) :: non_neg_integer()

Get the number of currently monitored subscribers.