Decorates an observable to split its output into a prefix of fixed size plus an observable remainder. More...

#include <prefix_and_tail.hpp>

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

Public Types
using	tuple_t = cow_tuple<cow_vector<T>, observable<T>>

using	super = cold<tuple_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
	prefix_and_tail (coordinator *parent, observable< T > decorated, size_t prefix_size)

disposable	subscribe (observer< tuple_t > out) override

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

Public Member Functions inherited from caf::flow::op::base< T >
virtual disposable	subscribe (observer< T > what)=0
	Subscribes a new observer to the operator.

Additional Inherited Members
Protected Attributes inherited from caf::flow::op::cold< cow_tuple< cow_vector< T >, observable< 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::prefix_and_tail< T >

Decorates an observable to split its output into a prefix of fixed size plus an observable remainder.

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

Public Types