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

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

buffered() const noexcept (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
cancel() final	caf::flow::subscription::impl_base	virtual
coordinated_ptr typedef (defined in caf::flow::coordinated)	caf::flow::coordinated	related
default_max_pending_per_input	caf::flow::op::merge_sub< T >	static
demand() const noexcept (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
deref() const noexcept	caf::detail::plain_ref_counted
deref_coordinated() const noexcept final	caf::flow::op::merge_sub< T >	virtual
deref_disposable() const noexcept override (defined in caf::flow::subscription::impl_base)	caf::flow::subscription::impl_base
dispose() final (defined in caf::flow::subscription::impl_base)	caf::flow::subscription::impl_base
disposed() const noexcept override (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
fwd_on_complete(input_key key) (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
fwd_on_error(input_key key, const error &what) (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
fwd_on_next(input_key key, const T &item) (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
fwd_on_subscribe(input_key key, subscription sub) (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
get_reference_count() const noexcept	caf::detail::plain_ref_counted
handle_type typedef (defined in caf::flow::subscription::impl)	caf::flow::subscription::impl
input_key typedef (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
input_map typedef (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
input_map_iterator typedef (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
intrusive_ptr_add_ref (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >	friend
intrusive_ptr_release (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >	friend
is_pulling() const noexcept	caf::flow::op::pullable
max_concurrent() const noexcept (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
merge_sub(coordinator *parent, observer< T > out, size_t max_concurrent, size_t max_pending_per_input=default_max_pending_per_input) (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
num_inputs() const noexcept (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
on_complete() override (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
on_error(const error &what) override (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
on_next(const observable< T > &what) override (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
on_subscribe(flow::subscription sub) override (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
operator=(const plain_ref_counted &) (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted
operator=(const pullable &)=delete (defined in caf::flow::op::pullable)	caf::flow::op::pullable
parent() const noexcept override	caf::flow::op::merge_sub< T >	virtual
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
pull(flow::coordinator *parent, size_t n) (defined in caf::flow::op::pullable)	caf::flow::op::pullable	protected
pullable() (defined in caf::flow::op::pullable)	caf::flow::op::pullable
pullable(const pullable &)=delete (defined in caf::flow::op::pullable)	caf::flow::op::pullable
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 final	caf::flow::op::merge_sub< T >	virtual
ref_disposable() const noexcept override (defined in caf::flow::subscription::impl_base)	caf::flow::subscription::impl_base
request(size_t n) override	caf::flow::op::merge_sub< T >	virtual
subscribed() const noexcept (defined in caf::flow::op::merge_sub< T >)	caf::flow::op::merge_sub< T >
unique() const noexcept	caf::detail::plain_ref_counted
~coordinated() (defined in caf::flow::coordinated)	caf::flow::coordinated	virtual
~impl() override (defined in caf::flow::subscription::impl)	caf::flow::subscription::impl
~plain_ref_counted() (defined in caf::detail::plain_ref_counted)	caf::detail::plain_ref_counted	virtual
~pullable() (defined in caf::flow::op::pullable)	caf::flow::op::pullable	virtual