caf::stream_manager Member List

This is the complete list of members for caf::stream_manager, including all inherited members.

abort(error reason)	caf::stream_manager	virtual
ack_batch(const stream_id &sid, const actor_addr &hdl, long new_demand, int64_t cumulative_batch_id)	caf::stream_manager	virtual
ack_open(const stream_id &sid, const actor_addr &rebind_from, strong_actor_ptr rebind_to, long initial_demand, bool redeployable)	caf::stream_manager	virtual
add_sink(const stream_id &sid, strong_actor_ptr origin, strong_actor_ptr sink_ptr, mailbox_element::forwarding_stack stages, message_id handshake_mid, message handshake_data, stream_priority prio, bool redeployable)	caf::stream_manager	virtual
add_source(const stream_id &sid, strong_actor_ptr source_ptr, strong_actor_ptr original_stage, stream_priority prio, bool redeployable, response_promise result_cb)	caf::stream_manager	virtual
batch(const stream_id &sid, const actor_addr &hdl, long xs_size, message &xs, int64_t xs_id)	caf::stream_manager	virtual
close(const stream_id &sid, const actor_addr &hdl)	caf::stream_manager	virtual
close()	caf::stream_manager	virtual
deref() noexcept	caf::ref_counted
done() const =0	caf::stream_manager	pure virtual
downstream_demand(outbound_path *ptr, long demand)	caf::stream_manager	protectedvirtual
drop(const stream_id &sid, const actor_addr &hdl)	caf::stream_manager	virtual
forced_close(const stream_id &sid, const actor_addr &hdl, error reason)	caf::stream_manager	virtual
forced_drop(const stream_id &sid, const actor_addr &hdl, error reason)	caf::stream_manager	virtual
generate_messages()	caf::stream_manager	virtual
get_reference_count() const noexcept (defined in caf::ref_counted)	caf::ref_counted
in()=0	caf::stream_manager	pure virtual
input_closed(error reason)	caf::stream_manager	protectedvirtual
intrusive_ptr_add_ref(ref_counted *p)	caf::ref_counted	related
intrusive_ptr_release(ref_counted *p)	caf::ref_counted	related
make_final_result()	caf::stream_manager	protectedvirtual
make_output_token(const stream_id &) const	caf::stream_manager	protectedvirtual
open(const stream_id &sid, strong_actor_ptr hdl, strong_actor_ptr original_stage, stream_priority priority, bool redeployable, response_promise result_cb)	caf::stream_manager	virtual
operator=(const ref_counted &) (defined in caf::ref_counted)	caf::ref_counted
out()=0	caf::stream_manager	pure virtual
output_closed(error reason)	caf::stream_manager	protectedvirtual
process_batch(message &msg)	caf::stream_manager	protectedvirtual
push()	caf::stream_manager	virtual
rc_ (defined in caf::ref_counted)	caf::ref_counted	protected
ref() noexcept	caf::ref_counted
ref_counted() (defined in caf::ref_counted)	caf::ref_counted
ref_counted(const ref_counted &) (defined in caf::ref_counted)	caf::ref_counted
request_deletion(bool decremented_rc) noexcept	caf::memory_managed	virtual
self_	caf::stream_manager	protected
stream_manager_ptr typedef	caf::stream_manager	related
unique() const noexcept	caf::ref_counted
~memory_managed() (defined in caf::memory_managed)	caf::memory_managed	protectedvirtual
~ref_counted() override (defined in caf::ref_counted)	caf::ref_counted
~stream_manager() override (defined in caf::stream_manager)	caf::stream_manager