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 >
atomic_ref_counted() (defined in caf::detail::atomic_ref_counted)	caf::detail::atomic_ref_counted
atomic_ref_counted(const atomic_ref_counted &) (defined in caf::detail::atomic_ref_counted)	caf::detail::atomic_ref_counted
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 >
coordinated_ptr typedef (defined in caf::flow::coordinated)	caf::flow::coordinated	related
deref() const noexcept	caf::detail::atomic_ref_counted
deref_coordinated() const noexcept override	caf::flow::op::publish< T >	virtual
empty_subscription(observer< T > &out)	caf::flow::op::base< T >	related
err_ (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >	protected
fail_subscription(observer< T > &out, const error &err)	caf::flow::op::base< T >	related
get_reference_count() const noexcept	caf::detail::atomic_ref_counted
handle_type typedef	caf::flow::op::base< T >
has_observers() const noexcept (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
hot(coordinator *parent) (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 *parent) (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_consumed_some(state_type *, size_t, size_t) override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >
on_disposed(state_type *ptr, bool from_external) final (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< 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 atomic_ref_counted &) (defined in caf::detail::atomic_ref_counted)	caf::detail::atomic_ref_counted
output_type typedef	caf::flow::op::base< T >
parent() const noexcept override	caf::flow::op::publish< T >	virtual
parent_ (defined in caf::flow::op::hot< T >)	caf::flow::op::hot< T >	protected
publish(coordinator *parent, 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::atomic_ref_counted)	caf::detail::atomic_ref_counted	mutableprotected
ref() const noexcept	caf::detail::atomic_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::publish< T >)	caf::flow::op::publish< 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::atomic_ref_counted
~atomic_ref_counted() (defined in caf::detail::atomic_ref_counted)	caf::detail::atomic_ref_counted	virtual
~coordinated() (defined in caf::flow::coordinated)	caf::flow::coordinated	virtual
~mcast() override (defined in caf::flow::op::mcast< T >)	caf::flow::op::mcast< T >
~publish() override (defined in caf::flow::op::publish< T >)	caf::flow::op::publish< T >