Module async_server

Structs

HangingGet

Deprecated: New code should use [async_utils::hanging_get::server::HangingGet].

HangingGetBroker

A Send wrapper for a HangingGet that can receive messages via an async channel. The HangingGetBroker is the primary way of implementing server side hanging get using this library. It manages all state and reacts to inputs sent over channels.

Publisher

A Publisher is used to make changes to the state contained within a HangingGetBroker. It is designed to be cheaply cloned and Send.

Subscriber

A Subscriber can be used to register observation requests with the HangingGetBroker. These observations will be fulfilled when the state changes or immediately the first time a Subscriber registers an observation.

SubscriptionRegistrar

A cheaply copyable handle that can be used to register new Subscribers with the HangingGetBroker.

Constants

DEFAULT_CHANNEL_SIZE

Default value that can be passed to HangingGetBroker::new by clients. If passed in, this will be used for all MPSC channels created by the broker.