Module sc_utils::pubsub

source ·
Expand description

Provides means to implement a typical Pub/Sub mechanism.

This module provides a type Hub which can be used both to subscribe, and to send the broadcast messages.

The Hub type is parametrized by two other types:

  • Message — the type of a message that shall be delivered to the subscribers;
  • Registry — implementation of the subscription/dispatch logic.

A Registry is implemented by defining the following traits:

As a result of subscription Hub::subscribe method returns an instance of Receiver<Message,Registry>. That can be used as a Stream to receive the messages. Upon drop the Receiver<Message, Registry> shall unregister itself from the Hub.

Structs§

  • A subscription hub.
  • The receiving side of the subscription.

Traits§

  • Dispatch a message of type M.
  • Subscribe using a key of type K
  • Unsubscribe: unregisters a previously created subscription.