abort(error reason) | caf::downstream_manager | 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 | |
buf() (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
buf() const (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
buf_ (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | protected |
buffer_type typedef (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
buffered() const noexcept override | caf::buffered_downstream_manager< T > | virtual |
caf::downstream_manager_base::buffered(stream_slot slot) const noexcept | caf::downstream_manager | virtual |
buffered_downstream_manager(stream_manager *parent) (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | explicit |
buffered_downstream_manager(stream_manager *parent, type_id_t type) (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
capacity() const noexcept override | caf::buffered_downstream_manager< T > | 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::downstream_manager_base | protectedvirtual |
chunk_type typedef (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
clean() const noexcept | caf::downstream_manager | |
clean(stream_slot slot) const noexcept | caf::downstream_manager | |
clear_paths() override | caf::downstream_manager_base | virtual |
close() | caf::downstream_manager | virtual |
close(stream_slot slot) | caf::downstream_manager | 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 | |
downstream_manager_base(stream_manager *parent) (defined in caf::downstream_manager_base) | caf::downstream_manager_base | explicit |
downstream_manager_base(stream_manager *parent, type_id_t type) (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
dropped_messages(size_t num) (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
emit_batches() | caf::downstream_manager | 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::downstream_manager_base | protectedvirtual |
force_emit_batches() | caf::downstream_manager | virtual |
generated_messages(size_t num) (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
get_chunk(buffer_type &buf, size_t n) | caf::buffered_downstream_manager< T > | static |
get_chunk(size_t n) (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
insert_path(unique_path_ptr ptr) override | caf::downstream_manager_base | protectedvirtual |
last_send_ | caf::downstream_manager | protected |
map_type typedef | caf::downstream_manager_base | |
max_credit() const | caf::downstream_manager | |
metrics_ (defined in caf::downstream_manager_base) | caf::downstream_manager_base | protected |
min_credit() const | caf::downstream_manager | |
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::downstream_manager_base | virtual |
open_path_slots() | caf::downstream_manager | |
operator=(const downstream_manager &)=delete (defined in caf::downstream_manager) | caf::downstream_manager | |
output_type typedef (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
parent() const noexcept (defined in caf::downstream_manager) | caf::downstream_manager | |
parent_ (defined in caf::downstream_manager) | caf::downstream_manager | protected |
path(stream_slot slots) noexcept override | caf::downstream_manager_base | virtual |
caf::downstream_manager::path(stream_slot slot) const noexcept | caf::downstream_manager | |
path_algorithm enum name | caf::downstream_manager | |
path_ptr typedef | caf::downstream_manager | |
path_slots() | caf::downstream_manager | |
path_type typedef | caf::downstream_manager | |
paths() const (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
paths() (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
paths_ (defined in caf::downstream_manager_base) | caf::downstream_manager_base | protected |
push(T0 &&x, Ts &&... xs) (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
remove_path(stream_slot slots, error reason, bool silent) noexcept override | caf::downstream_manager_base | virtual |
self() const noexcept (defined in caf::downstream_manager) | caf::downstream_manager | |
shipped_messages(size_t num) (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |
stalled() const noexcept | caf::downstream_manager | |
super typedef (defined in caf::buffered_downstream_manager< T >) | caf::buffered_downstream_manager< T > | |
terminal() const noexcept override | caf::buffered_downstream_manager< T > | virtual |
tick(time_point now, timespan max_batch_delay) | caf::downstream_manager | |
time_point typedef | caf::downstream_manager | |
total_credit() const | caf::downstream_manager | |
unique_path_ptr typedef | caf::downstream_manager | |
~downstream_manager() (defined in caf::downstream_manager) | caf::downstream_manager | virtual |
~downstream_manager_base() override (defined in caf::downstream_manager_base) | caf::downstream_manager_base | |