Implementation of the defer operator. More...

#include <defer.hpp>

Inheritance diagram for caf::flow::op::defer< Factory >:

Public Types
using	output_type = typename defer_trait<Factory>::output_type

using	super = cold<output_type>

Public Types inherited from caf::flow::op::base< defer_trait< Factory >::output_type >
using	super
	The derived type.

using	output_type
	The type of observed values.

using	handle_type
	The proper type for holding a type-erased handle to object instances.

Public Member Functions
	defer (coordinator *parent, Factory fn)

disposable	subscribe (observer< output_type > what) override

Public Member Functions inherited from caf::flow::op::cold< defer_trait< Factory >::output_type >
	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< defer_trait< Factory >::output_type >
virtual disposable	subscribe (observer< defer_trait< Factory >::output_type > what)=0
	Subscribes a new observer to the operator.

Additional Inherited Members
Protected Attributes inherited from caf::flow::op::cold< defer_trait< Factory >::output_type >
coordinator *	parent_

Protected Attributes inherited from caf::detail::atomic_ref_counted
std::atomic< size_t >	rc_

Related Symbols inherited from caf::flow::op::base< defer_trait< Factory >::output_type >
disposable	fail_subscription (observer< defer_trait< Factory >::output_type > &out, const error &err)
	Calls `on_subscribe` and `on_error` on `out` to immediately fail a subscription.

disposable	empty_subscription (observer< defer_trait< Factory >::output_type > &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 Factory>
class caf::flow::op::defer< Factory >

Implementation of the defer operator.

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

Public Types