Commit 2f2d6d79 authored by Dominik Charousset's avatar Dominik Charousset

Fix compilation errors

parent c8a35b24
...@@ -85,7 +85,7 @@ public: ...@@ -85,7 +85,7 @@ public:
bool all_filters(UnaryPredicate predicate) { bool all_filters(UnaryPredicate predicate) {
return std::all_of(state_map_.begin(), state_map_.end(), return std::all_of(state_map_.begin(), state_map_.end(),
[&](const typename state_map_type::value_type& kvp) { [&](const typename state_map_type::value_type& kvp) {
return predicate(kvp.second); return predicate(kvp.second.filter);
}); });
} }
...@@ -95,7 +95,7 @@ public: ...@@ -95,7 +95,7 @@ public:
bool any_filter(UnaryPredicate predicate) { bool any_filter(UnaryPredicate predicate) {
return std::any_of(state_map_.begin(), state_map_.end(), return std::any_of(state_map_.begin(), state_map_.end(),
[&](const typename state_map_type::value_type& kvp) { [&](const typename state_map_type::value_type& kvp) {
return predicate(kvp.second); return predicate(kvp.second.filter);
}); });
} }
...@@ -105,7 +105,7 @@ public: ...@@ -105,7 +105,7 @@ public:
bool no_filter(UnaryPredicate predicate) { bool no_filter(UnaryPredicate predicate) {
return std::none_of(state_map_.begin(), state_map_.end(), return std::none_of(state_map_.begin(), state_map_.end(),
[&](const typename state_map_type::value_type& kvp) { [&](const typename state_map_type::value_type& kvp) {
return predicate(kvp.second); return predicate(kvp.second.filter);
}); });
} }
......
...@@ -133,7 +133,7 @@ public: ...@@ -133,7 +133,7 @@ public:
fused_downstream_manager(scheduled_actor* self) fused_downstream_manager(scheduled_actor* self)
: super(self), : super(self),
nested_(self, detail::pack_repeat<Ts...>(self)) { nested_(self, detail::pack_repeat<Ts>(self)...) {
detail::init_ptr_array<0, sizeof...(Ts) + 1>::apply(ptrs_, nested_); detail::init_ptr_array<0, sizeof...(Ts) + 1>::apply(ptrs_, nested_);
} }
......
...@@ -167,7 +167,8 @@ using int_downstream_manager = broadcast_downstream_manager<int>; ...@@ -167,7 +167,8 @@ using int_downstream_manager = broadcast_downstream_manager<int>;
using string_downstream_manager = broadcast_downstream_manager<string>; using string_downstream_manager = broadcast_downstream_manager<string>;
using downstream_manager = fused_downstream_manager<int_downstream_manager, string_downstream_manager>; using fused_manager =
fused_downstream_manager<int_downstream_manager, string_downstream_manager>;
class fused_stage : public stream_manager { class fused_stage : public stream_manager {
public: public:
...@@ -207,12 +208,12 @@ public: ...@@ -207,12 +208,12 @@ public:
return out_.capacity() == 0; return out_.capacity() == 0;
} }
downstream_manager& out() noexcept override { fused_manager& out() noexcept override {
return out_; return out_;
} }
private: private:
downstream_manager out_; fused_manager out_;
}; };
TESTEE_STATE(stream_multiplexer) { TESTEE_STATE(stream_multiplexer) {
......
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