caf::flow::op::publish< T > Member List

This is the complete list of members for caf::flow::op::publish< T >, including all inherited members.

abort(const error &reason) (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
add_state(observer_type out) (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
auto_connect_threshold(size_t new_value) (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
auto_disconnect(bool new_value) (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
close() (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
closed_ (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >	protected
connect() (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
connected() const noexcept (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
ctx() const noexcept override	caf::flow::op::hot< T >	virtual
ctx_ (defined in caf::flow::op::hot< T >)	caf::flow::op::hot< T >	protected
deref() const noexcept	caf::detail::plain_ref_counted
deref_coordinated() const noexcept override	caf::flow::op::publish< T >	virtual
err_ (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >	protected
get_reference_count() const noexcept	caf::detail::plain_ref_counted
has_observers() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
hot(coordinator *ctx) (defined in caf::flow::op::hot< T >)	caf::flow::op::hot< T >	explicit
intrusive_ptr_add_ref (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >	friend
intrusive_ptr_release (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >	friend
max_buffered() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
max_demand() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
mcast(coordinator *ctx) (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >	explicit
min_buffered() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
min_demand() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
observer_count() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
observer_type typedef (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
on_complete() override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
on_error(const error &what) override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
on_next(const T &item) override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
on_subscribe(subscription in) override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
operator=(const plain_ref_counted &) (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted
output_type typedef (defined in caf::flow::op::hot< T >)	caf::flow::op::hot< T >
plain_ref_counted() (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted
plain_ref_counted(const plain_ref_counted &) (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted
publish(coordinator *ctx, src_ptr src, size_t max_buf_size=defaults::flow::buffer_size) (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
push_all(const T &item) (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
rc_ (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted	mutableprotected
ref() const noexcept	caf::detail::plain_ref_counted
ref_coordinated() const noexcept override	caf::flow::op::publish< T >	virtual
src_ptr typedef (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
state_ptr_type typedef (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
state_type typedef (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
states_ (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >	protected
subscribe(observer< T > out) override	caf::flow::op::publish< T >	virtual
super typedef (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
try_request_more() (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >	protected
unique() const noexcept	caf::detail::plain_ref_counted
~coordinated() (defined in caf::flow::coordinated)	caf::flow::coordinated	virtual
~plain_ref_counted() (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted	virtual