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

The subscription object for interfacing an observer with the cell state. More...

#include <cell.hpp>

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

Public Member Functions
	cell_sub (coordinator *ctx, cell_sub_state_ptr< T > state, observer< T > out)
bool	disposed () const noexcept override
void	dispose () override
void	request (size_t) override
	Signals demand for n more items.
void	on_next (const T &item) override
void	on_complete () override
void	on_error (const error &what) override
void	ref_listener () const noexcept override
void	deref_listener () const noexcept override
Public Member Functions inherited from caf::flow::subscription::impl_base
void	ref_disposable () const noexcept final
void	deref_disposable () const noexcept final
Public Member Functions inherited from caf::detail::plain_ref_counted
	plain_ref_counted (const plain_ref_counted &)
plain_ref_counted &	operator= (const plain_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 void	request (size_t n)=0
	Signals demand for n more items.
Public Member Functions inherited from caf::disposable::impl
virtual void	dispose ()=0
virtual bool	disposed () const noexcept=0
disposable	as_disposable () noexcept
virtual void	ref_disposable () const noexcept=0
virtual void	deref_disposable () const noexcept=0
virtual void	on_next (const T &item)=0
virtual void	on_complete ()=0
virtual void	on_error (const error &what)=0
virtual void	ref_listener () const noexcept=0
virtual void	deref_listener () const noexcept=0

Friends
void	intrusive_ptr_add_ref (const cell_sub *ptr) noexcept
void	intrusive_ptr_release (const cell_sub *ptr) noexcept

Additional Inherited Members
Protected Attributes inherited from caf::detail::plain_ref_counted
size_t	rc_

Detailed Description

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

The subscription object for interfacing an observer with the cell state.

Member Function Documentation

deref_listener()

template<class T >

void caf::flow::op::cell_sub< T >::deref_listener ( ) const

overridevirtualnoexcept

Implements caf::flow::op::cell_listener< T >.

dispose()

template<class T >

void caf::flow::op::cell_sub< T >::dispose ( )

overridevirtual

Implements caf::disposable::impl.

disposed()

template<class T >

bool caf::flow::op::cell_sub< T >::disposed ( ) const

overridevirtualnoexcept

Implements caf::disposable::impl.

on_complete()

template<class T >

void caf::flow::op::cell_sub< T >::on_complete ( )

overridevirtual

Implements caf::flow::op::cell_listener< T >.

on_error()

template<class T >

void caf::flow::op::cell_sub< T >::on_error ( const error &  what )

overridevirtual

Implements caf::flow::op::cell_listener< T >.

on_next()

template<class T >

void caf::flow::op::cell_sub< T >::on_next ( const T &  item )

overridevirtual

Implements caf::flow::op::cell_listener< T >.

ref_listener()

template<class T >

void caf::flow::op::cell_sub< T >::ref_listener ( ) const

overridevirtualnoexcept

Implements caf::flow::op::cell_listener< T >.

request()

template<class T >

void caf::flow::op::cell_sub< T >::request ( size_t  n )

overridevirtual

Signals demand for n more items.

Implements caf::flow::subscription::impl.

---

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

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