| abort(error reason) override | caf::stream_gatherer_impl | virtual |
| aborter_type | caf::stream_edge_impl< stream_gatherer > | static |
| add_path(const stream_id &sid, strong_actor_ptr x, strong_actor_ptr original_stage, stream_priority prio, long available_credit, bool redeployable, response_promise result_cb) override | caf::stream_gatherer_impl | virtual |
| add_path_impl(const stream_id &sid, strong_actor_ptr x) | caf::stream_edge_impl< stream_gatherer > | protected |
| assign_credit(long downstream_capacity) override | caf::random_gatherer | virtual |
| assignment_pair typedef (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | |
| assignment_vec_ (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | protected |
| close(message result) override | caf::stream_gatherer_impl | virtual |
| close_impl(F f) (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | protected |
| closed() const override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| continuous() const override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| continuous(bool value) override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| continuous_ (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | protected |
| emit_credits() (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | protected |
| find(PathContainer &xs, const stream_id &sid, const Handle &x) | caf::stream_edge_impl< stream_gatherer > | static |
| find(const stream_id &sid, const actor_addr &x) override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| caf::stream_gatherer::find(const stream_id &sid, const strong_actor_ptr &x) | caf::stream_gatherer | |
| fold(PathContainer &xs, T init, F f) (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | static |
| high_watermark() const override | caf::stream_gatherer_impl | virtual |
| high_watermark(long x) override | caf::stream_gatherer_impl | virtual |
| high_watermark_ (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | protected |
| initial_credit(long downstream_capacity, path_type *x) override (defined in caf::random_gatherer) | caf::random_gatherer | |
| caf::stream_gatherer_impl::initial_credit(long downstream_capacity, path_ptr x)=0 | caf::stream_gatherer | pure virtual |
| irregular_shutdown typedef | caf::stream_edge_impl< stream_gatherer > | |
| iter_find(PathContainer &xs, const stream_id &sid, const Handle &x) | caf::stream_edge_impl< stream_gatherer > | static |
| listeners_ | caf::stream_gatherer_impl | protected |
| max_credit() const override | caf::stream_gatherer_impl | virtual |
| max_credit(long x) override | caf::stream_gatherer_impl | virtual |
| max_credit_ (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | protected |
| min_credit_assignment() const override | caf::stream_gatherer_impl | virtual |
| min_credit_assignment(long x) override | caf::stream_gatherer_impl | virtual |
| min_credit_assignment_ (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | protected |
| num_paths() const override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| path_at(size_t index) override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | virtual |
| path_ptr typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_ptr_iter typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_ptr_vec typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_type typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_uptr typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_uptr_iter typedef | caf::stream_edge_impl< stream_gatherer > | |
| path_uptr_vec typedef | caf::stream_edge_impl< stream_gatherer > | |
| paths() const | caf::stream_edge_impl< stream_gatherer > | |
| paths_ (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | protected |
| random_gatherer(local_actor *selfptr) (defined in caf::random_gatherer) | caf::random_gatherer | |
| regular_shutdown typedef | caf::stream_edge_impl< stream_gatherer > | |
| remove_path(const stream_id &sid, const actor_addr &x, error reason, bool silent) override | caf::stream_gatherer_impl | virtual |
| remove_path(path_uptr_iter i, error reason, bool silent) (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | |
| caf::stream_gatherer::remove_path(const stream_id &sid, const strong_actor_ptr &x, error reason, bool silent) | caf::stream_gatherer | |
| self() const | caf::stream_edge_impl< stream_gatherer > | |
| self_ (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | protected |
| sort_by_credit(PathContainer &xs) | caf::stream_edge_impl< stream_gatherer > | static |
| stream_edge_impl(local_actor *selfptr) (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | |
| stream_gatherer()=default (defined in caf::stream_gatherer) | caf::stream_gatherer | |
| stream_gatherer_impl(local_actor *selfptr) (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | |
| super typedef (defined in caf::random_gatherer) | caf::random_gatherer | |
| ~random_gatherer() override (defined in caf::random_gatherer) | caf::random_gatherer | |
| ~stream_edge_impl() override (defined in caf::stream_edge_impl< stream_gatherer >) | caf::stream_edge_impl< stream_gatherer > | |
| ~stream_gatherer() (defined in caf::stream_gatherer) | caf::stream_gatherer | virtual |
| ~stream_gatherer_impl() (defined in caf::stream_gatherer_impl) | caf::stream_gatherer_impl | |
