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

#include <zip_with.hpp>

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

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

using	super = cold<output_type>

Public Types inherited from caf::flow::op::base< zip_with_output_t< F, Ts... > >
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
	zip_with (coordinator *parent, F fn, observable< Ts >... inputs)

disposable	subscribe (observer< output_type > out) override

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

Additional Inherited Members
Protected Attributes inherited from caf::flow::op::cold< zip_with_output_t< F, Ts... > >
coordinator *	parent_

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

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

disposable	empty_subscription (observer< zip_with_output_t< F, Ts... > > &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 F, class... Ts>
class caf::flow::op::zip_with< F, Ts >

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

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

Public Types