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 |
![]() | |
using | output_type = 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. | |
![]() | |
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. | |
![]() | |
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. | |
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 | |
![]() | |
coordinator * | ctx_ |
![]() | |
std::atomic< 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 >.