abort(error reason) override | caf::fused_downstream_manager< T, Ts > | virtual |
about_to_erase(path_ptr ptr, bool silent, error *reason) | caf::downstream_manager | protectedvirtual |
add_path(stream_slot slot, strong_actor_ptr target) | caf::downstream_manager | |
all_of enum value (defined in caf::downstream_manager) | caf::downstream_manager | |
all_paths(Predicate predicate) const noexcept | caf::downstream_manager | |
any_of enum value (defined in caf::downstream_manager) | caf::downstream_manager | |
any_path(Predicate predicate) const noexcept | caf::downstream_manager | |
assign(stream_slot slot) | caf::fused_downstream_manager< T, Ts > | |
buffered() const noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
buffered(stream_slot slot) const noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
capacity() const noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
check_paths(path_algorithm algorithm, Predicate predicate) const noexcept | caf::downstream_manager | protected |
check_paths_impl(path_algorithm algo, path_predicate &pred) const noexcept override | caf::fused_downstream_manager< T, Ts > | protectedvirtual |
clean() const noexcept | caf::downstream_manager | |
clean(stream_slot slot) const noexcept | caf::downstream_manager | |
clear_paths() override | caf::fused_downstream_manager< T, Ts > | virtual |
close() override | caf::fused_downstream_manager< T, Ts > | virtual |
close() | caf::fused_downstream_manager< T, Ts > | virtual |
close(stream_slot slot) | caf::fused_downstream_manager< T, Ts > | virtual |
const_path_ptr typedef | caf::downstream_manager | |
downstream_manager(stream_manager *parent) (defined in caf::downstream_manager) | caf::downstream_manager | explicit |
downstream_manager(const downstream_manager &)=delete (defined in caf::downstream_manager) | caf::downstream_manager | |
emit_batches() override | caf::fused_downstream_manager< T, Ts > | virtual |
empty() const noexcept | caf::downstream_manager | |
for_each_path(F f) | caf::downstream_manager | |
for_each_path(F f) const | caf::downstream_manager | |
for_each_path_impl(path_visitor &f) override | caf::fused_downstream_manager< T, Ts > | protectedvirtual |
force_emit_batches() override | caf::fused_downstream_manager< T, Ts > | virtual |
fused_downstream_manager(stream_manager *parent) (defined in caf::fused_downstream_manager< T, Ts >) | caf::fused_downstream_manager< T, Ts > | |
get() (defined in caf::fused_downstream_manager< T, Ts >) | caf::fused_downstream_manager< T, Ts > | |
get() const (defined in caf::fused_downstream_manager< T, Ts >) | caf::fused_downstream_manager< T, Ts > | |
insert_path(unique_path_ptr ptr) override | caf::fused_downstream_manager< T, Ts > | protectedvirtual |
last_send_ | caf::downstream_manager | protected |
map_type typedef | caf::fused_downstream_manager< T, Ts > | |
max_credit() const | caf::downstream_manager | |
min_credit() const | caf::downstream_manager | |
nested_managers typedef | caf::fused_downstream_manager< T, Ts > | |
no_path(Predicate predicate) const noexcept | caf::downstream_manager | |
none_of enum value (defined in caf::downstream_manager) | caf::downstream_manager | |
num_paths() const noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
open_path_slots() | caf::downstream_manager | |
operator=(const downstream_manager &)=delete (defined in caf::downstream_manager) | caf::downstream_manager | |
param_list typedef (defined in caf::fused_downstream_manager< T, Ts >) | caf::fused_downstream_manager< T, Ts > | |
parent() const noexcept (defined in caf::downstream_manager) | caf::downstream_manager | |
parent_ (defined in caf::downstream_manager) | caf::downstream_manager | protected |
path(stream_slot slot) noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
caf::downstream_manager::path(stream_slot slot) const noexcept | caf::downstream_manager | |
path_algorithm enum name | caf::downstream_manager | |
path_ptr typedef | caf::fused_downstream_manager< T, Ts > | |
path_slots() | caf::downstream_manager | |
path_type typedef | caf::downstream_manager | |
remove_path(stream_slot slot, error reason, bool silent) noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
self() const noexcept (defined in caf::downstream_manager) | caf::downstream_manager | |
stalled() const noexcept | caf::downstream_manager | |
super typedef | caf::fused_downstream_manager< T, Ts > | |
terminal() const noexcept override | caf::fused_downstream_manager< T, Ts > | virtual |
tick(time_point now, timespan max_batch_delay) | caf::downstream_manager | |
time_point typedef | caf::downstream_manager | |
total_credit() const | caf::downstream_manager | |
unassigned_map_type typedef | caf::fused_downstream_manager< T, Ts > | |
unique_path_ptr typedef | caf::fused_downstream_manager< T, Ts > | |
~downstream_manager() (defined in caf::downstream_manager) | caf::downstream_manager | virtual |