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

Combines items from any number of observables. More...

#include <concat.hpp>

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

Public Types
using	input_key = size_t
using	input_type = std::variant< observable< T >, observable< observable< T > > >

Public Member Functions
	concat_sub (coordinator *ctx, observer< T > out, std::vector< input_type > inputs)
void	subscribe_to (observable< T > what)
void	subscribe_to (observable< observable< T > > what)
void	subscribe_next ()
void	fwd_on_subscribe (input_key key, subscription sub)
void	fwd_on_complete (input_key key)
void	fwd_on_error (input_key key, const error &what)
void	fwd_on_next (input_key key, const T &item)
void	fwd_on_next (input_key key, const observable< T > &item)
bool	disposed () const noexcept override
void	dispose () override
void	request (size_t n) override
	Signals demand for n more items.
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

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

Detailed Description

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

Combines items from any number of observables.

Member Function Documentation

dispose()

template<class T >

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

overridevirtual

Implements caf::disposable::impl.

disposed()

template<class T >

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

overridevirtualnoexcept

Implements caf::disposable::impl.

request()

template<class T >

void caf::flow::op::concat_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/concat.hpp