| abort(error reason) override | caf::stream_scatterer_impl | virtual |
| aborter_type | caf::stream_edge_impl< stream_scatterer > | static |
| add_lane(filter_type f) (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| add_path(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) override | caf::stream_scatterer_impl | virtual |
| add_path_impl(const stream_id &sid, strong_actor_ptr x) | caf::stream_edge_impl< stream_scatterer > | protected |
| broadcast_topic_scatterer(local_actor *selfptr) (defined in caf::broadcast_topic_scatterer< T, Filter, Select >) | caf::broadcast_topic_scatterer< T, Filter, Select > | |
| buf() (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| buf() const (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| buf_ (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | protected |
| buffer_type typedef (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| buffered() const override | caf::buffered_scatterer< T > | virtual |
| buffered_scatterer(local_actor *selfptr) (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| chunk_type typedef (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| close() override | caf::stream_scatterer_impl | virtual |
| close_impl(F f) (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | protected |
| closed() const override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| confirm_path(const stream_id &sid, const actor_addr &from, strong_actor_ptr to, long initial_demand, bool redeployable) override | caf::stream_scatterer_impl | virtual |
| continuous() const override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| continuous(bool value) override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| continuous_ (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | protected |
| credit() const override | caf::broadcast_topic_scatterer< T, Filter, Select > | virtual |
| emit_batches() override | caf::broadcast_topic_scatterer< T, Filter, Select > | virtual |
| erase_from_lane(lane &l, typename super::path_ptr ptr) (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | protected |
| erase_from_lanes(typename super::path_ptr ptr) (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | protected |
| fan_out() | caf::topic_scatterer< T, Filter, Select > | protected |
| filter_type typedef | caf::topic_scatterer< T, Filter, Select > | |
| find(PathContainer &xs, const stream_id &sid, const Handle &x) | caf::stream_edge_impl< stream_scatterer > | static |
| find(const stream_id &sid, const actor_addr &x) override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| caf::stream_scatterer::find(const stream_id &sid, const strong_actor_ptr &x) | caf::stream_scatterer | |
| fold(PathContainer &xs, T init, F f) (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | static |
| fold_credit(const PathContainer &xs, long x0, F f) | caf::stream_scatterer_impl | static |
| get_chunk(buffer_type &buf, long n) | caf::buffered_scatterer< T > | static |
| get_chunk(long n) (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| irregular_shutdown typedef | caf::stream_edge_impl< stream_scatterer > | |
| iter_find(PathContainer &xs, const stream_id &sid, const Handle &x) | caf::stream_edge_impl< stream_scatterer > | static |
| lanes() const (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| lanes_ (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | protected |
| lanes_map typedef (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| max_batch_delay() const override | caf::stream_scatterer_impl | virtual |
| max_batch_delay(duration x) override | caf::stream_scatterer_impl | virtual |
| max_batch_delay_ (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | protected |
| max_batch_size() const override | caf::stream_scatterer_impl | virtual |
| max_batch_size(long x) override | caf::stream_scatterer_impl | virtual |
| max_batch_size_ (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | protected |
| max_credit(const PathContainer &xs) (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | static |
| max_credit() const | caf::stream_scatterer_impl | |
| min_batch_size() const override | caf::stream_scatterer_impl | virtual |
| min_batch_size(long x) override | caf::stream_scatterer_impl | virtual |
| min_batch_size_ (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | protected |
| min_buffer_size() const override | caf::stream_scatterer_impl | virtual |
| min_buffer_size(long x) override | caf::stream_scatterer_impl | virtual |
| min_buffer_size_ (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | protected |
| min_credit(const PathContainer &xs) | caf::stream_scatterer_impl | static |
| min_credit() const | caf::stream_scatterer_impl | |
| num_paths() const override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| path_at(size_t index) override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | virtual |
| path_ptr typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_ptr_iter typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_ptr_vec typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_type typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_uptr typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_uptr_iter typedef | caf::stream_edge_impl< stream_scatterer > | |
| path_uptr_vec typedef | caf::stream_edge_impl< stream_scatterer > | |
| paths() const | caf::stream_edge_impl< stream_scatterer > | |
| paths_ (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | protected |
| paths_clean() const override | caf::stream_scatterer_impl | virtual |
| push(T0 &&x, Ts &&... xs) (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| regular_shutdown typedef | caf::stream_edge_impl< stream_scatterer > | |
| remove_path(const stream_id &sid, const actor_addr &x, error reason, bool silent) override | caf::topic_scatterer< T, Filter, Select > | virtual |
| remove_path(path_uptr_iter i, error reason, bool silent) (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | |
| caf::stream_scatterer::remove_path(const stream_id &sid, const strong_actor_ptr &x, error reason, bool silent) | caf::stream_scatterer | |
| select_ (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | protected |
| selected(const filter_type &f, const T &x) | caf::topic_scatterer< T, Filter, Select > | protected |
| selector() (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| selector() const (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| self() const | caf::stream_edge_impl< stream_scatterer > | |
| self_ (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | protected |
| set_filter(const stream_id &sid, const Handle &x, filter_type f) | caf::topic_scatterer< T, Filter, Select > | |
| sort_by_credit(PathContainer &xs) | caf::stream_edge_impl< stream_scatterer > | static |
| stream_edge_impl(local_actor *selfptr) (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | |
| stream_scatterer()=default (defined in caf::stream_scatterer) | caf::stream_scatterer | |
| stream_scatterer_impl(local_actor *selfptr) (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | |
| super typedef | caf::broadcast_topic_scatterer< T, Filter, Select > | |
| topic_scatterer(local_actor *selfptr) (defined in caf::topic_scatterer< T, Filter, Select >) | caf::topic_scatterer< T, Filter, Select > | |
| total_credit(const PathContainer &xs) | caf::stream_scatterer_impl | static |
| total_credit() const | caf::stream_scatterer_impl | |
| value_type typedef (defined in caf::buffered_scatterer< T >) | caf::buffered_scatterer< T > | |
| ~stream_edge_impl() override (defined in caf::stream_edge_impl< stream_scatterer >) | caf::stream_edge_impl< stream_scatterer > | |
| ~stream_scatterer() (defined in caf::stream_scatterer) | caf::stream_scatterer | virtual |
| ~stream_scatterer_impl() override (defined in caf::stream_scatterer_impl) | caf::stream_scatterer_impl | |
