|
C++ Actor Framework 1.0.0
|
Convenience base type for cold observable types. More...
#include <cold.hpp>
Public Member Functions | |
| cold (coordinator *parent) | |
| void | ref_coordinated () const noexcept override |
| Increases the reference count of the coordinated. | |
| void | deref_coordinated () const noexcept override |
| Decreases the reference count of the coordinated and destroys the object if necessary. | |
| coordinator * | parent () const noexcept override |
| Returns the coordinator this object lives on. | |
Public Member Functions inherited from caf::detail::atomic_ref_counted | |
| atomic_ref_counted (const atomic_ref_counted &) | |
| atomic_ref_counted & | operator= (const atomic_ref_counted &) |
| void | ref () const noexcept |
| Increases reference count by one. | |
| void | deref () const noexcept |
Decreases reference count by one and calls request_deletion when it drops to zero. | |
| bool | unique () const noexcept |
| Queries whether there is exactly one reference. | |
| size_t | get_reference_count () const noexcept |
| Queries the current reference count for this object. | |
Public Member Functions inherited from caf::flow::op::base< T > | |
| virtual disposable | subscribe (observer< T > what)=0 |
| Subscribes a new observer to the operator. | |
Protected Attributes | |
| coordinator * | parent_ |
Protected Attributes inherited from caf::detail::atomic_ref_counted | |
| std::atomic< size_t > | rc_ |
Additional Inherited Members | |
Public Types inherited from caf::flow::op::base< T > | |
| using | super = coordinated |
| The derived type. | |
| using | output_type = T |
| The type of observed values. | |
| using | handle_type = observable<T> |
| The proper type for holding a type-erased handle to object instances. | |
Related Symbols inherited from caf::flow::op::base< T > | |
| disposable | fail_subscription (observer< T > &out, const error &err) |
Calls on_subscribe and on_error on out to immediately fail a subscription. | |
| disposable | empty_subscription (observer< T > &out) |
Calls on_subscribe and on_complete on out to immediately complete a subscription. | |
Related Symbols inherited from caf::flow::coordinated | |
| using | coordinated_ptr = intrusive_ptr<coordinated> |
Convenience base type for cold observable types.
|
overridevirtualnoexcept |
Decreases the reference count of the coordinated and destroys the object if necessary.
Implements caf::flow::coordinated.
|
overridevirtualnoexcept |
Returns the coordinator this object lives on.
Implements caf::flow::coordinated.
|
overridevirtualnoexcept |
Increases the reference count of the coordinated.
Implements caf::flow::coordinated.