123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- #pragma once
- #include "plugin_base.h"
- namespace rotor::plugin {
- struct lifetime_plugin_t : public plugin_base_t {
- using plugin_base_t::plugin_base_t;
-
- static const void *class_identity;
- const void *identity() const noexcept override;
- void activate(actor_base_t *actor) noexcept override;
- void deactivate() noexcept override;
-
- void initate_subscription(const subscription_info_ptr_t &info) noexcept;
-
- void unsubscribe(const handler_ptr_t &h, const address_ptr_t &addr) noexcept;
-
- void unsubscribe(const subscription_info_ptr_t &info) noexcept;
-
- virtual void on_subscription(message::subscription_t &) noexcept;
-
- virtual void on_unsubscription(message::unsubscription_t &) noexcept;
-
- virtual void on_unsubscription_external(message::unsubscription_external_t &) noexcept;
- bool handle_unsubscription(const subscription_point_t &point, bool external) noexcept override;
- bool handle_shutdown(message::shutdown_request_t *message) noexcept override;
-
- template <typename T> auto &access() noexcept;
- private:
- void unsubscribe() noexcept;
-
- subscription_container_t points;
- bool ready_to_shutdown() noexcept;
- };
- }
|