Module manager

Source
Expand description

The SubscriptionManager used to manage subscription based RPCs.

The manager provides four main things in terms of functionality:

  1. The ability to create unique subscription IDs through the use of the IdProvider trait. Two implementations are availble out of the box, a NumericIdProvider and a RandomStringIdProvider.

  2. An executor with which to drive Futures to completion.

  3. A way to add new subscriptions. Subscriptions should come in the form of a Stream. These subscriptions will be transformed into notifications by the manager, which can be consumed by the client.

  4. A way to cancel any currently active subscription.

Structs§

NumericIdProvider
Provides a thread-safe incrementing integer which can be used as a subscription ID.
RandomStringIdProvider
Used to generate random strings for use as subscription IDs.
SubscriptionManager
Subscriptions manager.

Traits§

IdProvider
Trait used to provide unique subscription IDs.

Type Aliases§

TaskExecutor
Cloneable Spawn handle.