caf::flow::op::base< T > Class Template Reference

Abstract base type for all flow operators that implement the observable concept. More...

#include <base.hpp>

Inheritance diagram for caf::flow::op::base< T >:

Public Types
using	output_type = T
	The type of observed values.

Public Member Functions
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.
Public Member Functions inherited from caf::flow::coordinated
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.

Detailed Description

template<class T>
class caf::flow::op::base< T >

Abstract base type for all flow operators that implement the observable concept.

Member Function Documentation

ctx()

template<class T >

virtual coordinator * caf::flow::op::base< T >::ctx ( ) const

pure virtualnoexcept

Returns the coordinator that executes this flow operator.

Implemented in caf::flow::op::cold< T >, caf::flow::op::cold< Trait::output_type >, caf::flow::op::cold< defer_trait< Factory >::output_type >, caf::flow::op::cold< from_steps_output_t< Steps... > >, caf::flow::op::cold< int64_t >, caf::flow::op::cold< cow_tuple< cow_vector< T >, observable< T > > >, caf::flow::op::cold< zip_with_output_t< F, Ts... > >, caf::flow::op::hot< T >, caf::flow::op::hot< async::batch >, and caf::flow::op::hot< from_generator_output_t< Generator, Steps... > >.

subscribe()

template<class T >

virtual disposable caf::flow::op::base< T >::subscribe ( observer< T >  what )

pure virtual

Subscribes a new observer to the operator.

Implemented in caf::flow::op::empty< T >, caf::flow::op::never< T >, and caf::flow::op::publish< T >.

---

The documentation for this class was generated from the following file:

• libcaf_core/caf/flow/op/base.hpp