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	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.

Public Member Functions
virtual disposable	subscribe (observer< T > what)=0
	Subscribes a new observer to the operator.
Public Member Functions inherited from caf::flow::coordinated
virtual coordinator *	parent () const noexcept=0
	Returns the coordinator this object lives on.
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.

Related Symbols
(Note that these are not member symbols.)
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>

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

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::fail< T >, caf::flow::op::never< T >, caf::flow::op::on_backpressure_buffer< T >, and caf::flow::op::publish< T >.

---

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

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