| acquire_credit(inbound_path *path, int32_t desired) | caf::stream_manager | virtual |
| add_unchecked_inbound_path_impl(type_id_t input_type, inbound_path_ptr path) | caf::stream_manager | protected |
| assign_next_pending_slot() (defined in caf::stream_manager) | caf::stream_manager | protected |
| assign_next_slot() (defined in caf::stream_manager) | caf::stream_manager | protected |
| congested(const inbound_path &path) const noexcept | caf::stream_manager | virtual |
| continuous() const noexcept | caf::stream_manager | |
| continuous(bool x) noexcept | caf::stream_manager | |
| cycle_timeout(size_t cycle_nr) | caf::stream_manager | virtual |
| deliver_handshake(response_promise &rp, stream_slot slot, message handshake) | caf::stream_manager | virtual |
| deref() const noexcept | caf::ref_counted | |
| deregister_input_path(inbound_path *x) noexcept | caf::stream_manager | virtual |
| done() const override | caf::detail::stream_distribution_tree< Policy > | virtual |
| downstream_demand(outbound_path *ptr, long demand) | caf::stream_manager | protectedvirtual |
| downstream_manager_type typedef (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| finalize(const error &reason) (defined in caf::stream_manager) | caf::stream_manager | protectedvirtual |
| flags_ | caf::stream_manager | protected |
| generate_messages() | caf::stream_manager | virtual |
| get_inbound_path(stream_slot x) const noexcept | caf::stream_manager | |
| get_reference_count() const noexcept (defined in caf::ref_counted) | caf::ref_counted | |
| handle(inbound_path *path, downstream_msg::batch &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(inbound_path *path, downstream_msg::close &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(inbound_path *path, downstream_msg::forced_close &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(stream_slots slots, upstream_msg::ack_open &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(stream_slots slots, upstream_msg::drop &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(stream_slots slots, upstream_msg::forced_drop &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual |
| handle(stream_slots slots, upstream_msg::ack_batch &x) (defined in caf::stream_manager) | caf::stream_manager | virtual |
| idle() const noexcept override | caf::detail::stream_distribution_tree< Policy > | virtual |
| inbound_path_ptr typedef (defined in caf::stream_manager) | caf::stream_manager | |
| inbound_paths() const noexcept | caf::stream_manager | |
| inbound_paths_ | caf::stream_manager | protected |
| inbound_paths_idle() const noexcept | caf::stream_manager | |
| inbound_paths_list typedef (defined in caf::stream_manager) | caf::stream_manager | |
| input_closed(error reason) | caf::stream_manager | protectedvirtual |
| intrusive_ptr_add_ref(const ref_counted *p) (defined in caf::ref_counted) | caf::ref_counted | related |
| intrusive_ptr_release(const ref_counted *p) (defined in caf::ref_counted) | caf::ref_counted | related |
| is_continuous_flag | caf::stream_manager | static |
| is_shutting_down_flag | caf::stream_manager | static |
| is_stopped_flag | caf::stream_manager | static |
| make_copy_on_write(Ts &&... xs) | caf::ref_counted | related |
| make_counted(Ts &&... xs) | caf::ref_counted | related |
| max_batch_delay_ | caf::stream_manager | protected |
| operator=(const ref_counted &) (defined in caf::ref_counted) | caf::ref_counted | |
| out() override | caf::detail::stream_distribution_tree< Policy > | virtual |
| caf::stream_manager::out() const | caf::stream_manager | |
| output_closed(error reason) | caf::stream_manager | protectedvirtual |
| pending_handshakes_ | caf::stream_manager | protected |
| policy() (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| policy() const (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| priority_ | caf::stream_manager | protected |
| push() | caf::stream_manager | virtual |
| rc_ (defined in caf::ref_counted) | caf::ref_counted | mutableprotected |
| ref() const 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 | |
| register_input_path(inbound_path *x) | caf::stream_manager | virtual |
| remove_input_path(stream_slot slot, error reason, bool silent) | caf::stream_manager | virtual |
| running() const noexcept | caf::stream_manager | |
| self() noexcept | caf::stream_manager | |
| self_ | caf::stream_manager | protected |
| shutdown() | caf::stream_manager | virtual |
| stop(error reason=none) | caf::stream_manager | virtual |
| stream_distribution_tree(scheduled_actor *selfptr, Ts &&... xs) (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| stream_manager(scheduled_actor *selfptr, stream_priority prio=stream_priority::normal) (defined in caf::stream_manager) | caf::stream_manager | |
| stream_manager_ptr typedef | caf::stream_manager | related |
| super typedef (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| tick(time_point now) (defined in caf::stream_manager) | caf::stream_manager | |
| time_point typedef | caf::stream_manager | |
| unique() const noexcept | caf::ref_counted | |
| ~ref_counted() (defined in caf::ref_counted) | caf::ref_counted | virtual |
| ~stream_distribution_tree() override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | |
| ~stream_manager() override (defined in caf::stream_manager) | caf::stream_manager | |
