An observable that never calls any callbacks on its subscribers. More...

#include <never.hpp>

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

Public Types
using	super = cold<T>

Public Types inherited from caf::flow::op::base< T >
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
	never (coordinator *parent)

disposable	subscribe (observer< T > out) override
	Subscribes a new observer to the operator.

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

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

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

Related Symbols inherited from caf::flow::op::base< T >
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::never< T >

An observable that never calls any callbacks on its subscribers.

Member Function Documentation

template<class T >

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

overridevirtual

Subscribes a new observer to the operator.

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