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

State shared between one multicast operator and one subscribed observer. More...

#include <ucast.hpp>

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

Public Member Functions
	ucast_sub_state (coordinator *ptr)
	ucast_sub_state (coordinator *ctx, observer< T > out)
void	push (const T &item)
void	close ()
void	abort (const error &reason)
void	dispose ()
void	do_run ()
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.

Public Attributes
coordinator *	ctx
std::deque< T >	buf
size_t	demand = 0
observer< T >	out
bool	disposed = false
bool	closed = false
bool	running = false
error	err
action	when_disposed
action	when_consumed_some
action	when_demand_changed

Friends
void	intrusive_ptr_add_ref (const ucast_sub_state *ptr) noexcept
void	intrusive_ptr_release (const ucast_sub_state *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::ucast_sub_state< T >

State shared between one multicast operator and one subscribed observer.

---

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

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