|
C++ Actor Framework 0.19
|
An observable that represents an empty range. More...
#include <empty.hpp>
Public Types | |
| using | super = cold< T > |
| using | output_type = T |
Public Types inherited from caf::flow::op::cold< T > | |
| using | output_type = T |
Public Types inherited from caf::flow::op::base< T > | |
| using | output_type = T |
| The type of observed values. | |
Public Member Functions | |
| empty (coordinator *ctx) | |
| disposable | subscribe (observer< output_type > out) override |
| Subscribes a new observer to the operator. | |
Public Member Functions inherited from caf::flow::op::cold< T > | |
| cold (coordinator *ctx) | |
| 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 * | ctx () const noexcept override |
| Returns the coordinator that executes this flow operator. | |
Public Member Functions inherited from caf::detail::plain_ref_counted | |
| plain_ref_counted (const plain_ref_counted &) | |
| plain_ref_counted & | operator= (const plain_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. | |
| virtual coordinator * | ctx () const noexcept=0 |
| Returns the coordinator that executes this flow operator. | |
| virtual disposable | subscribe (observer< T > what)=0 |
| Subscribes a new observer to the operator. | |
| virtual void | ref_coordinated () const noexcept=0 |
| Increases the reference count of the coordinated. | |
| virtual void | deref_coordinated () const noexcept=0 |
| Decreases the reference count of the coordinated and destroys the object if necessary. | |
Additional Inherited Members | |
Protected Attributes inherited from caf::flow::op::cold< T > | |
| coordinator * | ctx_ |
Protected Attributes inherited from caf::detail::plain_ref_counted | |
| size_t | rc_ |
An observable that represents an empty range.
As soon as an observer requests values from this observable, it calls on_complete.
|
overridevirtual |
Subscribes a new observer to the operator.
Implements caf::flow::op::base< T >.