subscription_point_t with extended information (e.g. state)
More...
#include <subscription_point.h>
Public Types | |
| enum | state_t { SUBSCRIBING , ESTABLISHED , UNSUBSCRIBING } |
| subscription info state (subscribing, established, unsubscribing | |
Public Member Functions | |
| subscription_info_t (const subscription_point_t &point, bool internal_address_, bool internal_handler_, state_t state_) noexcept | |
| ctor from subscription point, internal address and internal handler and state | |
| void | tag_io () noexcept |
| marks handler for blocking operations | |
| template<typename T> | |
| auto & | access () noexcept |
| generic non-public fields accessor | |
| template<typename T, typename... Args> | |
| auto | access (Args... args) noexcept |
| generic non-public methods accessor | |
| Public Member Functions inherited from rotor::subscription_point_t | |
| subscription_point_t (const handler_ptr_t &handler_, const address_ptr_t &address_) noexcept | |
| ctor from handler and related address (used for comparison) | |
| subscription_point_t (const handler_ptr_t &handler_, const address_ptr_t &address_, const actor_base_t *owner_ptr_, owner_tag_t owner_tag_) noexcept | |
| full ctor (handler, address, actor, and owner tag) | |
| subscription_point_t (const subscription_point_t &)=default | |
| copy-ctor | |
| subscription_point_t (subscription_point_t &&)=default | |
| move-ctor | |
| bool | operator== (const subscription_point_t &other) const |
| partial comparison by handler and address | |
Additional Inherited Members | |
| Public Attributes inherited from rotor::subscription_point_t | |
| handler_ptr_t | handler |
| intrusive pointer to messages' handler | |
| address_ptr_t | address |
| intrusive pointer to address | |
| const actor_base_t * | owner_ptr |
| non-owning pointer to an actor, which performs subscription | |
| owner_tag_t | owner_tag |
| kind of ownership of the subscription point | |
subscription_point_t with extended information (e.g. state)
|
inlinenoexcept |
marks handler for blocking operations
It is suitable for thread backend.