caf::flow::op::zip_with_sub< F, Ts > Class Template Reference

Combines items from any number of observables using a zip function. More...

#include <zip_with.hpp>

Inheritance diagram for caf::flow::op::zip_with_sub< F, Ts >:

Public Types
using	output_type = zip_with_output_t< F, Ts... >

Public Member Functions
	zip_with_sub (coordinator *ctx, F fn, observer< output_type > out, std::tuple< observable< Ts >... > &srcs)
bool	disposed () const noexcept override
void	dispose () override
void	request (size_t n) override
	Signals demand for n more items.
template<size_t I>
auto &	at (zip_index< I >)
template<class Fn , size_t... Is>
void	for_each_input (Fn &&fn, std::index_sequence< Is... >)
template<class Fn >
void	for_each_input (Fn &&fn)
template<class Fn , size_t... Is>
auto	fold (Fn &&fn, std::index_sequence< Is... >)
template<class Fn >
auto	fold (Fn &&fn)
size_t	buffered ()
bool	at_end ()
template<size_t I>
void	fwd_on_subscribe (zip_index< I > index, subscription sub)
template<size_t I>
void	fwd_on_complete (zip_index< I > index)
template<size_t I>
void	fwd_on_error (zip_index< I > index, const error &what)
template<size_t I, class T >
void	fwd_on_next (zip_index< I > index, const T &item)
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 F, class... Ts>
class caf::flow::op::zip_with_sub< F, Ts >

Combines items from any number of observables using a zip function.

Member Function Documentation

dispose()

template<class F , class... Ts>

void caf::flow::op::zip_with_sub< F, Ts >::dispose ( )

overridevirtual

Implements caf::disposable::impl.

disposed()

template<class F , class... Ts>

bool caf::flow::op::zip_with_sub< F, Ts >::disposed ( ) const

overridevirtualnoexcept

Implements caf::disposable::impl.

request()

template<class F , class... Ts>

void caf::flow::op::zip_with_sub< F, Ts >::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/zip_with.hpp