Commit 472c25d9 authored by Dominik Charousset's avatar Dominik Charousset

Remove dead code

parent de5c1d85
......@@ -73,13 +73,6 @@ public:
/// Returns the path associated to `slots` or `nullptr`.
path_ptr path(stream_slot slots) noexcept;
/// Returns the stored state for `x` if `x` is a known path and associated to
/// `sid`, otherwise `nullptr`.
path_ptr path_at(size_t index) noexcept;
/// Removes a path from the scatterer and returns it.
path_unique_ptr take_path_at(size_t index) noexcept;
/// Returns `true` if there is no data pending and no unacknowledged batch on
/// any path.
bool clean() const noexcept;
......
......@@ -71,20 +71,6 @@ pointer stream_scatterer::path(stream_slot slot) noexcept {
return i != paths_.end() ? i->second.get() : nullptr;
}
pointer stream_scatterer::path_at(size_t index) noexcept {
CAF_ASSERT(paths_.size() < index);
return (paths_.container())[index].second.get();
}
unique_pointer stream_scatterer::take_path_at(size_t index) noexcept {
CAF_ASSERT(paths_.size() < index);
unique_pointer result;
auto i = paths_.begin() + index;
result.swap(i->second);
paths_.erase(i);
return result;
}
bool stream_scatterer::clean() const noexcept {
auto pred = [](const map_type::value_type& kvp) {
auto& p = *kvp.second;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment